| 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 |
SocketChannelStream.openAsync(AsyncCompletionHandler<java.lang.Void> handler) |
void |
AsynchronousSocketChannelStream.openAsync(AsyncCompletionHandler<java.lang.Void> handler) |
void |
SocketStream.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 |
SocketChannelStream.readAsync(int numBytes,
AsyncCompletionHandler<ByteBuf> handler) |
void |
AsynchronousSocketChannelStream.readAsync(int numBytes,
AsyncCompletionHandler<ByteBuf> handler) |
void |
SocketStream.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 |
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 |
SocketStream.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) |