private BsonDocument |
QueryProtocol.asFindCommandDocument(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
(package private) static java.util.List<ByteBufBsonDocument> |
ByteBufBsonDocument.createList(ByteBufferBsonOutput bsonOutput,
int startPosition) |
(package private) static ByteBufBsonDocument |
ByteBufBsonDocument.createOne(ByteBufferBsonOutput bsonOutput,
int startPosition) |
protected BsonDocument |
DeleteProtocol.getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
protected BsonDocument |
UpdateProtocol.getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
protected abstract BsonDocument |
WriteProtocol.getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
protected BsonDocument |
InsertProtocol.getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
(package private) BsonDocument |
CommandMessage.getCommandDocument(ByteBufferBsonOutput bsonOutput) |
private void |
InternalStreamConnection.sendCommandMessage(CommandMessage message,
InternalStreamConnection.LazyCommandDocument lazyCommandDocument,
ByteBufferBsonOutput bsonOutput,
SessionContext sessionContext) |
private <T> void |
InternalStreamConnection.sendCommandMessageAsync(int messageId,
Decoder<T> decoder,
SessionContext sessionContext,
SingleResultCallback<T> callback,
ByteBufferBsonOutput bsonOutput,
InternalStreamConnection.CommandEventSender commandEventSender,
boolean responseExpected) |
private boolean |
QueryProtocol.sendQueryStartedEvent(InternalConnection connection,
QueryMessage message,
ByteBufferBsonOutput bsonOutput,
RequestMessage.EncodingMetadata metadata) |
private void |
WriteProtocol.sendStartedEvent(InternalConnection connection,
RequestMessage message,
RequestMessage.EncodingMetadata encodingMetadata,
ByteBufferBsonOutput bsonOutput) |