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 TypeClassDescriptionclassAnIoFutureimplementation that wraps a different type ofIoFuture.classAn abstract base class forIoFutureobjects.classAn implementation ofIoFuturethat represents an immediately-failed operation.classAn implementation ofIoFuturethat 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 anIoFuturewhich 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 theIoFuturefor 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 voidWait for all the futures to complete.static voidIoUtils.awaitAllInterruptibly(IoFuture<?>... futures) Wait for all the futures to complete.static <I,O> IoFuture<? extends O> Create anIoFuturewhich wraps anotherIoFuture, but returns a different type.static <T> Future<T>Get ajava.util.concurrent-styleFutureinstance wrapper for anIoFutureinstance.voidReceive notification of the completion of an outstanding operation.voidReceive notification of the completion of an outstanding operation.static voidClose a future resource, logging an error if an error occurs.ModifierConstructorDescriptionprotectedAbstractConvertingIoFuture(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.