Uses of Interface
org.xnio.IoFuture
Packages that use IoFuture
Package
Description
The main API package for XNIO.
Utility classes for using and implementing SSL within XNIO providers.
-
Uses of IoFuture in org.xnio
Modifier and TypeClassDescriptionclass
AnIoFuture
implementation that wraps a different type ofIoFuture
.class
An abstract base class forIoFuture
objects.class
An implementation ofIoFuture
that represents an immediately-failed operation.class
An implementation ofIoFuture
that represents an immediately-successful operation.Modifier and TypeMethodDescriptionChannelDestination.accept
(ChannelListener<? super T> openListener, ChannelListener<? super BoundChannel> bindListener) Accept a connection.XnioWorker.acceptDatagram
(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.XnioIoFactory.acceptMessageConnection
(SocketAddress destination, ChannelListener<? super MessageConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Accept a message connection at a destination address.XnioIoThread.acceptMessageConnection
(SocketAddress destination, ChannelListener<? super MessageConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) XnioWorker.acceptMessageConnection
(SocketAddress destination, ChannelListener<? super MessageConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) XnioWorker.acceptStream
(SocketAddress destination, ChannelListener<? super ConnectedStreamChannel> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Deprecated.XnioIoFactory.acceptStreamConnection
(SocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Accept a stream connection at a destination address.XnioIoThread.acceptStreamConnection
(SocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) XnioWorker.acceptStreamConnection
(SocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) protected IoFuture<StreamConnection>
XnioIoThread.acceptTcpStreamConnection
(InetSocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Implementation helper method to accept a TCP connection.AbstractConvertingIoFuture.addNotifier
(IoFuture.Notifier<? super T, A> notifier, A attachment) AbstractIoFuture.addNotifier
(IoFuture.Notifier<? super T, A> notifier, A attachment) Add a notifier to be called when this operation is complete.FinishedIoFuture.addNotifier
(IoFuture.Notifier<? super T, A> notifier, A attachment) IoFuture.addNotifier
(IoFuture.Notifier<? super T, A> notifier, A attachment) Add a notifier to be called when this operation is complete.AbstractConvertingIoFuture.cancel()
AbstractIoFuture.cancel()
Cancel an operation.FailedIoFuture.cancel()
Cancel the operation.FinishedIoFuture.cancel()
Cancel the operation.IoFuture.cancel()
Cancel an operation.static <I,
O> IoFuture<? extends O> Create anIoFuture
which wraps anotherIoFuture
, but returns a different type.XnioWorker.connectDatagram
(SocketAddress bindAddress, SocketAddress destination, ChannelListener<? super ConnectedMessageChannel> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Deprecated.XnioWorker.connectDatagram
(SocketAddress destination, ChannelListener<? super ConnectedMessageChannel> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Deprecated.XnioWorker.connectStream
(SocketAddress bindAddress, SocketAddress destination, ChannelListener<? super ConnectedStreamChannel> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Deprecated.XnioWorker.connectStream
(SocketAddress destination, ChannelListener<? super ConnectedStreamChannel> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Deprecated.XnioWorker.connectStream
(SocketAddress destination, ChannelListener<? super ConnectedStreamChannel> openListener, OptionMap optionMap) Deprecated.AbstractConvertingIoFuture.getDelegate()
FutureResult.getIoFuture()
Get theIoFuture
for this manager.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.XnioIoFactory.openMessageConnection
(SocketAddress destination, ChannelListener<? super MessageConnection> openListener, OptionMap optionMap) Connect to a remote message server.XnioIoThread.openMessageConnection
(SocketAddress destination, ChannelListener<? super MessageConnection> openListener, OptionMap optionMap) XnioWorker.openMessageConnection
(SocketAddress destination, ChannelListener<? super MessageConnection> openListener, OptionMap optionMap) XnioIoFactory.openStreamConnection
(SocketAddress bindAddress, SocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Connect to a remote stream server.XnioIoFactory.openStreamConnection
(SocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Connect to a remote stream server.XnioIoFactory.openStreamConnection
(SocketAddress destination, ChannelListener<? super StreamConnection> openListener, OptionMap optionMap) Connect to a remote stream server.XnioIoThread.openStreamConnection
(SocketAddress bindAddress, SocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) XnioIoThread.openStreamConnection
(SocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) XnioIoThread.openStreamConnection
(SocketAddress destination, ChannelListener<? super StreamConnection> openListener, OptionMap optionMap) XnioWorker.openStreamConnection
(SocketAddress bindAddress, SocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) XnioWorker.openStreamConnection
(SocketAddress destination, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) XnioWorker.openStreamConnection
(SocketAddress destination, ChannelListener<? super StreamConnection> openListener, OptionMap optionMap) protected IoFuture<StreamConnection>
XnioIoThread.openTcpStreamConnection
(InetSocketAddress bindAddress, InetSocketAddress destinationAddress, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Implementation helper method to connect to a TCP server.Modifier and TypeMethodDescriptionstatic void
Wait for all the futures to complete.static void
IoUtils.awaitAllInterruptibly
(IoFuture<?>... futures) Wait for all the futures to complete.static <I,
O> IoFuture<? extends O> Create anIoFuture
which wraps anotherIoFuture
, but returns a different type.static <T> Future<T>
Get ajava.util.concurrent
-styleFuture
instance wrapper for anIoFuture
instance.void
Receive notification of the completion of an outstanding operation.void
Receive notification of the completion of an outstanding operation.static void
Close a future resource, logging an error if an error occurs.ModifierConstructorDescriptionprotected
AbstractConvertingIoFuture
(IoFuture<? extends D> delegate) -
Uses of IoFuture in org.xnio.http
Methods in org.xnio.http that return IoFutureModifier and TypeMethodDescriptionstatic IoFuture<StreamConnection>
HttpUpgrade.performUpgrade
(XnioWorker worker, InetSocketAddress bindAddress, URI uri, Map<String, String> headers, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap, HandshakeChecker handshakeChecker) Connects to the target server using HTTP upgrade.static IoFuture<StreamConnection>
HttpUpgrade.performUpgrade
(XnioWorker worker, InetSocketAddress bindAddress, URI uri, Map<String, List<String>> headers, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap, ExtendedHandshakeChecker handshakeChecker) Connects to the target server using HTTP upgrade.static IoFuture<SslConnection>
HttpUpgrade.performUpgrade
(XnioWorker worker, XnioSsl ssl, InetSocketAddress bindAddress, URI uri, Map<String, String> headers, ChannelListener<? super SslConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap, HandshakeChecker handshakeChecker) Perform a HTTP upgrade that results in a SSL secured connection.static IoFuture<SslConnection>
HttpUpgrade.performUpgrade
(XnioWorker worker, XnioSsl ssl, InetSocketAddress bindAddress, URI uri, Map<String, List<String>> headers, ChannelListener<? super SslConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap, ExtendedHandshakeChecker handshakeChecker) Perform a HTTP upgrade that results in a SSL secured connection.static <T extends StreamConnection>
IoFuture<T>HttpUpgrade.performUpgrade
(T connection, URI uri, Map<String, String> headers, ChannelListener<? super StreamConnection> openListener, HandshakeChecker handshakeChecker) Performs a HTTP upgrade on an existing connection.static <T extends StreamConnection>
IoFuture<T>HttpUpgrade.performUpgrade
(T connection, URI uri, Map<String, List<String>> headers, ChannelListener<? super StreamConnection> openListener, ExtendedHandshakeChecker handshakeChecker) Performs a HTTP upgrade on an existing connection. -
Uses of IoFuture in org.xnio.ssl
Methods in org.xnio.ssl that return IoFutureModifier and TypeMethodDescriptionJsseXnioSsl.connectSsl
(XnioWorker worker, InetSocketAddress bindAddress, InetSocketAddress destination, ChannelListener<? super ConnectedSslStreamChannel> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) abstract IoFuture<ConnectedSslStreamChannel>
XnioSsl.connectSsl
(XnioWorker worker, InetSocketAddress bindAddress, InetSocketAddress destination, ChannelListener<? super ConnectedSslStreamChannel> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Deprecated.XnioSsl.connectSsl
(XnioWorker worker, InetSocketAddress bindAddress, InetSocketAddress destination, ChannelListener<? super ConnectedSslStreamChannel> openListener, OptionMap optionMap) Deprecated.XnioSsl.connectSsl
(XnioWorker worker, InetSocketAddress destination, ChannelListener<? super ConnectedSslStreamChannel> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Deprecated.XnioSsl.connectSsl
(XnioWorker worker, InetSocketAddress destination, ChannelListener<? super ConnectedSslStreamChannel> openListener, OptionMap optionMap) Deprecated.JsseXnioSsl.openSslConnection
(XnioIoThread ioThread, InetSocketAddress bindAddress, InetSocketAddress destination, ChannelListener<? super SslConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) JsseXnioSsl.openSslConnection
(XnioWorker worker, InetSocketAddress bindAddress, InetSocketAddress destination, ChannelListener<? super SslConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) abstract IoFuture<SslConnection>
XnioSsl.openSslConnection
(XnioIoThread ioThread, InetSocketAddress bindAddress, InetSocketAddress destination, ChannelListener<? super SslConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Create an SSL connection to a remote host.XnioSsl.openSslConnection
(XnioIoThread ioThread, InetSocketAddress bindAddress, InetSocketAddress destination, ChannelListener<? super SslConnection> openListener, OptionMap optionMap) Create an SSL connection to a remote host.XnioSsl.openSslConnection
(XnioIoThread ioThread, InetSocketAddress destination, ChannelListener<? super SslConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Create an SSL connection to a remote host.XnioSsl.openSslConnection
(XnioIoThread ioThread, InetSocketAddress destination, ChannelListener<? super SslConnection> openListener, OptionMap optionMap) Create an SSL connection to a remote host.abstract IoFuture<SslConnection>
XnioSsl.openSslConnection
(XnioWorker worker, InetSocketAddress bindAddress, InetSocketAddress destination, ChannelListener<? super SslConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Create an SSL connection to a remote host.XnioSsl.openSslConnection
(XnioWorker worker, InetSocketAddress bindAddress, InetSocketAddress destination, ChannelListener<? super SslConnection> openListener, OptionMap optionMap) Create an SSL connection to a remote host.XnioSsl.openSslConnection
(XnioWorker worker, InetSocketAddress destination, ChannelListener<? super SslConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap) Create an SSL connection to a remote host.XnioSsl.openSslConnection
(XnioWorker worker, InetSocketAddress destination, ChannelListener<? super SslConnection> openListener, OptionMap optionMap) Create an SSL connection to a remote host.