class InternalStreamConnectionInitializer extends java.lang.Object implements InternalConnectionInitializer
Modifier and Type | Class and Description |
---|---|
private class |
InternalStreamConnectionInitializer.CompoundAuthenticator |
Modifier and Type | Field and Description |
---|---|
private java.util.List<Authenticator> |
authenticators |
private BsonDocument |
clientMetadataDocument |
Constructor and Description |
---|
InternalStreamConnectionInitializer(java.util.List<Authenticator> authenticators,
BsonDocument clientMetadataDocument) |
private final java.util.List<Authenticator> authenticators
private final BsonDocument clientMetadataDocument
InternalStreamConnectionInitializer(java.util.List<Authenticator> authenticators, BsonDocument clientMetadataDocument)
public ConnectionDescription initialize(InternalConnection internalConnection)
initialize
in interface InternalConnectionInitializer
public void initializeAsync(InternalConnection internalConnection, SingleResultCallback<ConnectionDescription> callback)
initializeAsync
in interface InternalConnectionInitializer
private SingleResultCallback<ConnectionDescription> createConnectionDescriptionCallback(InternalConnection internalConnection, SingleResultCallback<ConnectionDescription> callback)
private ConnectionDescription initializeConnectionDescription(InternalConnection internalConnection)
private BsonDocument createIsMasterCommand()
private ConnectionDescription completeConnectionDescriptionInitialization(InternalConnection internalConnection, ConnectionDescription connectionDescription)
private void authenticateAll(InternalConnection internalConnection, ConnectionDescription connectionDescription)
private void initializeConnectionDescriptionAsync(InternalConnection internalConnection, SingleResultCallback<ConnectionDescription> callback)
private void completeConnectionDescriptionInitializationAsync(InternalConnection internalConnection, ConnectionDescription connectionDescription, SingleResultCallback<ConnectionDescription> callback)
private ConnectionDescription applyGetLastErrorResult(BsonDocument getLastErrorResult, ConnectionDescription connectionDescription)