Package | Description |
---|---|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
com.mongodb.connection.netty |
This package contains netty specific classes
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
FutureAsyncCompletionHandler<T> |
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.atomic.AtomicReference<AsyncCompletionHandler<T>> |
AsynchronousSocketChannelStream.BaseCompletionHandler.handlerReference |
Modifier and Type | Method and Description |
---|---|
protected AsyncCompletionHandler<T> |
AsynchronousSocketChannelStream.BaseCompletionHandler.getHandlerAndClear() |
Modifier and Type | Method and Description |
---|---|
void |
SocketStream.openAsync(AsyncCompletionHandler<java.lang.Void> handler) |
void |
SocketChannelStream.openAsync(AsyncCompletionHandler<java.lang.Void> handler) |
void |
AsynchronousSocketChannelStream.openAsync(AsyncCompletionHandler<java.lang.Void> handler) |
void |
Stream.openAsync(AsyncCompletionHandler<java.lang.Void> handler)
Open the stream asynchronously.
|
private void |
AsynchronousSocketChannelStream.pipeOneBuffer(AsyncWritableByteChannel byteChannel,
ByteBuf byteBuffer,
AsyncCompletionHandler<java.lang.Void> outerHandler) |
void |
SocketStream.readAsync(int numBytes,
AsyncCompletionHandler<ByteBuf> handler) |
void |
SocketChannelStream.readAsync(int numBytes,
AsyncCompletionHandler<ByteBuf> handler) |
void |
AsynchronousSocketChannelStream.readAsync(int numBytes,
AsyncCompletionHandler<ByteBuf> handler) |
void |
Stream.readAsync(int numBytes,
AsyncCompletionHandler<ByteBuf> handler)
Read from the stream, asynchronously.
|
void |
AsyncWritableByteChannel.write(java.nio.ByteBuffer src,
AsyncCompletionHandler<java.lang.Void> handler)
Writes a sequence of bytes to this channel from the given buffer.
|
void |
AsynchronousSocketChannelStream.AsyncWritableByteChannelAdapter.write(java.nio.ByteBuffer src,
AsyncCompletionHandler<java.lang.Void> handler) |
void |
SocketStream.writeAsync(java.util.List<ByteBuf> buffers,
AsyncCompletionHandler<java.lang.Void> handler) |
void |
SocketChannelStream.writeAsync(java.util.List<ByteBuf> buffers,
AsyncCompletionHandler<java.lang.Void> handler) |
void |
AsynchronousSocketChannelStream.writeAsync(java.util.List<ByteBuf> buffers,
AsyncCompletionHandler<java.lang.Void> handler) |
void |
Stream.writeAsync(java.util.List<ByteBuf> buffers,
AsyncCompletionHandler<java.lang.Void> handler)
Write each buffer in the list to the stream in order, asynchronously.
|
Constructor and Description |
---|
BaseCompletionHandler(AsyncCompletionHandler<T> handler) |
BasicCompletionHandler(ByteBuf dst,
AsyncCompletionHandler<ByteBuf> handler) |
OpenCompletionHandler(AsyncCompletionHandler<java.lang.Void> handler) |
WriteCompletionHandler(AsyncCompletionHandler<java.lang.Void> handler) |
Modifier and Type | Class and Description |
---|---|
private static class |
NettyStream.FutureAsyncCompletionHandler<T> |
Modifier and Type | Field and Description |
---|---|
private AsyncCompletionHandler<ByteBuf> |
NettyStream.PendingReader.handler |
Modifier and Type | Method and Description |
---|---|
void |
NettyStream.openAsync(AsyncCompletionHandler<java.lang.Void> handler) |
void |
NettyStream.readAsync(int numBytes,
AsyncCompletionHandler<ByteBuf> handler) |
void |
NettyStream.writeAsync(java.util.List<ByteBuf> buffers,
AsyncCompletionHandler<java.lang.Void> handler) |
Constructor and Description |
---|
PendingReader(int numBytes,
AsyncCompletionHandler<ByteBuf> handler) |