com.mongodb.internal.connection

Class AsynchronousSocketChannelStream

java.lang.Object

com.mongodb.internal.connection.AsynchronousChannelStream

com.mongodb.internal.connection.AsynchronousSocketChannelStream

All Implemented Interfaces:

BufferProvider, Stream

public final class AsynchronousSocketChannelStream
extends AsynchronousChannelStream
implements Stream

Constructor Summary

Constructors

Constructor and Description
AsynchronousSocketChannelStream(ServerAddress serverAddress, SocketSettings settings, BufferProvider bufferProvider, java.nio.channels.AsynchronousChannelGroup group)

Method Summary

Modifier and Type	Method and Description
java.nio.channels.AsynchronousChannelGroup	getGroup()
void	openAsync(AsyncCompletionHandler<java.lang.Void> handler) Open the stream asynchronously.

Methods inherited from class com.mongodb.internal.connection.AsynchronousChannelStream

close, getAddress, getBuffer, getBufferProvider, getChannel, getServerAddress, getSettings, isClosed, open, read, readAsync, write, writeAsync

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.mongodb.connection.Stream

close, getAddress, isClosed, open, read, readAsync, write, writeAsync

Methods inherited from interface com.mongodb.connection.BufferProvider

getBuffer

Constructor Detail

AsynchronousSocketChannelStream

public AsynchronousSocketChannelStream(ServerAddress serverAddress,
                                       SocketSettings settings,
                                       BufferProvider bufferProvider,
                                       java.nio.channels.AsynchronousChannelGroup group)

Method Detail

openAsync

public void openAsync(AsyncCompletionHandler<java.lang.Void> handler)

Description copied from interface: Stream

Open the stream asynchronously.

Specified by:

openAsync in interface Stream

Parameters:

handler - the completion handler for opening the stream

getGroup

public java.nio.channels.AsynchronousChannelGroup getGroup()