IoFuture<? extends T> |
ChannelDestination.accept(ChannelListener<? super T> openListener,
ChannelListener<? super BoundChannel> bindListener) |
Accept a connection.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.acceptDatagram(java.net.SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Deprecated.
|
protected IoFuture<MessageConnection> |
XnioIoThread.acceptLocalMessageConnection(LocalSocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Implementation helper method to accept a local (UNIX domain) datagram connection.
|
protected IoFuture<StreamConnection> |
XnioIoThread.acceptLocalStreamConnection(LocalSocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Implementation helper method to accept a local (UNIX domain) stream connection.
|
IoFuture<MessageConnection> |
XnioIoFactory.acceptMessageConnection(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Accept a message connection at a destination address.
|
IoFuture<MessageConnection> |
XnioIoThread.acceptMessageConnection(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
|
IoFuture<MessageConnection> |
XnioWorker.acceptMessageConnection(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.acceptStream(java.net.SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Deprecated.
|
IoFuture<StreamConnection> |
XnioIoFactory.acceptStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Accept a stream connection at a destination address.
|
IoFuture<StreamConnection> |
XnioIoThread.acceptStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
|
IoFuture<StreamConnection> |
XnioWorker.acceptStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
|
protected IoFuture<StreamConnection> |
XnioIoThread.acceptTcpStreamConnection(java.net.InetSocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Implementation helper method to accept a TCP connection.
|
<A> IoFuture<T> |
AbstractConvertingIoFuture.addNotifier(IoFuture.Notifier<? super T,A> notifier,
A attachment) |
|
<A> IoFuture<T> |
AbstractIoFuture.addNotifier(IoFuture.Notifier<? super T,A> notifier,
A attachment) |
Add a notifier to be called when this operation is complete.
|
<A> IoFuture<T> |
FinishedIoFuture.addNotifier(IoFuture.Notifier<? super T,A> notifier,
A attachment) |
|
<A> IoFuture<T> |
IoFuture.addNotifier(IoFuture.Notifier<? super T,A> notifier,
A attachment) |
Add a notifier to be called when this operation is complete.
|
IoFuture<T> |
AbstractConvertingIoFuture.cancel() |
|
IoFuture<T> |
AbstractIoFuture.cancel() |
Cancel an operation.
|
IoFuture<T> |
FailedIoFuture.cancel() |
Cancel the operation.
|
IoFuture<T> |
FinishedIoFuture.cancel() |
Cancel the operation.
|
IoFuture<T> |
IoFuture.cancel() |
Cancel an operation.
|
static <I,O> IoFuture<? extends O> |
IoUtils.cast(IoFuture<I> parent,
java.lang.Class<O> type) |
Create an IoFuture which wraps another IoFuture , but returns a different type.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.connectDatagram(java.net.SocketAddress bindAddress,
java.net.SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Deprecated.
|
IoFuture<ConnectedMessageChannel> |
XnioWorker.connectDatagram(java.net.SocketAddress destination,
ChannelListener<? super ConnectedMessageChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Deprecated.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(java.net.SocketAddress bindAddress,
java.net.SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Deprecated.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(java.net.SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Deprecated.
|
IoFuture<ConnectedStreamChannel> |
XnioWorker.connectStream(java.net.SocketAddress destination,
ChannelListener<? super ConnectedStreamChannel> openListener,
OptionMap optionMap) |
Deprecated.
|
protected IoFuture<? extends D> |
AbstractConvertingIoFuture.getDelegate() |
|
IoFuture<T> |
FutureResult.getIoFuture() |
Get the IoFuture for this manager.
|
IoFuture<T> |
ChannelSource.open(ChannelListener<? super T> openListener) |
Open a channel.
|
protected IoFuture<MessageConnection> |
XnioIoThread.openLocalMessageConnection(LocalSocketAddress bindAddress,
LocalSocketAddress destinationAddress,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap) |
Implementation helper method to connect to a local (UNIX domain) server.
|
protected IoFuture<StreamConnection> |
XnioIoThread.openLocalStreamConnection(LocalSocketAddress bindAddress,
LocalSocketAddress destinationAddress,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Implementation helper method to connect to a local (UNIX domain) server.
|
IoFuture<MessageConnection> |
XnioIoFactory.openMessageConnection(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap) |
Connect to a remote message server.
|
IoFuture<MessageConnection> |
XnioIoThread.openMessageConnection(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap) |
|
IoFuture<MessageConnection> |
XnioWorker.openMessageConnection(java.net.SocketAddress destination,
ChannelListener<? super MessageConnection> openListener,
OptionMap optionMap) |
|
IoFuture<StreamConnection> |
XnioIoFactory.openStreamConnection(java.net.SocketAddress bindAddress,
java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioIoFactory.openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioIoFactory.openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap) |
Connect to a remote stream server.
|
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(java.net.SocketAddress bindAddress,
java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
|
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
|
IoFuture<StreamConnection> |
XnioIoThread.openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap) |
|
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(java.net.SocketAddress bindAddress,
java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
|
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
|
IoFuture<StreamConnection> |
XnioWorker.openStreamConnection(java.net.SocketAddress destination,
ChannelListener<? super StreamConnection> openListener,
OptionMap optionMap) |
|
protected IoFuture<StreamConnection> |
XnioIoThread.openTcpStreamConnection(java.net.InetSocketAddress bindAddress,
java.net.InetSocketAddress destinationAddress,
ChannelListener<? super StreamConnection> openListener,
ChannelListener<? super BoundChannel> bindListener,
OptionMap optionMap) |
Implementation helper method to connect to a TCP server.
|