Uses of Class
org.xnio.StreamConnection
-
Packages that use StreamConnection Package Description org.xnio The main API package for XNIO.org.xnio._private org.xnio.http org.xnio.ssl Utility classes for using and implementing SSL within XNIO providers. -
-
Uses of StreamConnection in org.xnio
Methods in org.xnio that return types with arguments of type StreamConnection Modifier and Type Method Description 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<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.ChannelPipe<StreamConnection,StreamConnection>XnioIoFactory. createFullDuplexPipeConnection()Create a two-way stream pipe.ChannelPipe<StreamConnection,StreamConnection>XnioIoFactory. createFullDuplexPipeConnection()Create a two-way stream pipe.ChannelPipe<StreamConnection,StreamConnection>XnioIoFactory. createFullDuplexPipeConnection(XnioIoFactory peer)Create a two-way stream pipe.ChannelPipe<StreamConnection,StreamConnection>XnioIoFactory. createFullDuplexPipeConnection(XnioIoFactory peer)Create a two-way stream pipe.ChannelPipe<StreamConnection,StreamConnection>XnioIoThread. createFullDuplexPipeConnection()ChannelPipe<StreamConnection,StreamConnection>XnioIoThread. createFullDuplexPipeConnection()ChannelPipe<StreamConnection,StreamConnection>XnioIoThread. createFullDuplexPipeConnection(XnioIoFactory peer)ChannelPipe<StreamConnection,StreamConnection>XnioIoThread. createFullDuplexPipeConnection(XnioIoFactory peer)ChannelPipe<StreamConnection,StreamConnection>XnioWorker. createFullDuplexPipeConnection()ChannelPipe<StreamConnection,StreamConnection>XnioWorker. createFullDuplexPipeConnection()ChannelPipe<StreamConnection,StreamConnection>XnioWorker. createFullDuplexPipeConnection(XnioIoFactory peer)ChannelPipe<StreamConnection,StreamConnection>XnioWorker. createFullDuplexPipeConnection(XnioIoFactory peer)protected AcceptingChannel<StreamConnection>XnioWorker. createLocalStreamConnectionServer(LocalSocketAddress bindAddress, ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener, OptionMap optionMap)Implementation helper method to create a UNIX domain stream server.AcceptingChannel<StreamConnection>XnioWorker. createStreamConnectionServer(java.net.SocketAddress bindAddress, ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener, OptionMap optionMap)Create a stream server, for TCP or UNIX domain servers.protected AcceptingChannel<StreamConnection>XnioWorker. createTcpConnectionServer(java.net.InetSocketAddress bindAddress, ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener, OptionMap optionMap)Implementation helper method to create a TCP stream server.ChannelListener<? super StreamConnection>StreamConnection. getCloseListener()ChannelListener.Setter<? extends StreamConnection>StreamConnection. getCloseSetter()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<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.Method parameters in org.xnio with type arguments of type StreamConnection Modifier and Type Method Description 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<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.protected AcceptingChannel<StreamConnection>XnioWorker. createLocalStreamConnectionServer(LocalSocketAddress bindAddress, ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener, OptionMap optionMap)Implementation helper method to create a UNIX domain stream server.AcceptingChannel<StreamConnection>XnioWorker. createStreamConnectionServer(java.net.SocketAddress bindAddress, ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener, OptionMap optionMap)Create a stream server, for TCP or UNIX domain servers.protected AcceptingChannel<StreamConnection>XnioWorker. createTcpConnectionServer(java.net.InetSocketAddress bindAddress, ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener, OptionMap optionMap)Implementation helper method to create a TCP stream 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<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.voidStreamConnection. setCloseListener(ChannelListener<? super StreamConnection> listener) -
Uses of StreamConnection in org.xnio._private
Methods in org.xnio._private with parameters of type StreamConnection Modifier and Type Method Description voidMessages_$logger. connectionNotifyReadClosedFailed(java.lang.Throwable cause, StreamConnection connection)voidMessages. connectionNotifyReadClosedFailed(java.lang.Throwable cause, StreamConnection connection)voidMessages_$logger. connectionNotifyWriteClosedFailed(java.lang.Throwable cause, StreamConnection connection)voidMessages. connectionNotifyWriteClosedFailed(java.lang.Throwable cause, StreamConnection connection) -
Uses of StreamConnection in org.xnio.http
Methods in org.xnio.http with type parameters of type StreamConnection Modifier and Type Method Description static <T extends StreamConnection>
IoFuture<T>HttpUpgrade. performUpgrade(T connection, java.net.URI uri, java.util.Map<java.lang.String,java.lang.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, java.net.URI uri, java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers, ChannelListener<? super StreamConnection> openListener, ExtendedHandshakeChecker handshakeChecker)Performs a HTTP upgrade on an existing connection.Methods in org.xnio.http that return types with arguments of type StreamConnection Modifier and Type Method Description static IoFuture<StreamConnection>HttpUpgrade. performUpgrade(XnioWorker worker, java.net.InetSocketAddress bindAddress, java.net.URI uri, java.util.Map<java.lang.String,java.lang.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, java.net.InetSocketAddress bindAddress, java.net.URI uri, java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap, ExtendedHandshakeChecker handshakeChecker)Connects to the target server using HTTP upgrade.Method parameters in org.xnio.http with type arguments of type StreamConnection Modifier and Type Method Description static IoFuture<StreamConnection>HttpUpgrade. performUpgrade(XnioWorker worker, java.net.InetSocketAddress bindAddress, java.net.URI uri, java.util.Map<java.lang.String,java.lang.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, java.net.InetSocketAddress bindAddress, java.net.URI uri, java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers, ChannelListener<? super StreamConnection> openListener, ChannelListener<? super BoundChannel> bindListener, OptionMap optionMap, ExtendedHandshakeChecker handshakeChecker)Connects to the target server using HTTP upgrade.static <T extends StreamConnection>
IoFuture<T>HttpUpgrade. performUpgrade(T connection, java.net.URI uri, java.util.Map<java.lang.String,java.lang.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, java.net.URI uri, java.util.Map<java.lang.String,java.util.List<java.lang.String>> headers, ChannelListener<? super StreamConnection> openListener, ExtendedHandshakeChecker handshakeChecker)Performs a HTTP upgrade on an existing connection. -
Uses of StreamConnection in org.xnio.ssl
Subclasses of StreamConnection in org.xnio.ssl Modifier and Type Class Description classJsseSslConnectionclassJsseSslStreamConnectionStreamConnection with SSL support.classSslConnectionA stream connection which can use SSL/TLS to negotiate a security layer.Constructors in org.xnio.ssl with parameters of type StreamConnection Constructor Description JsseSslConnection(StreamConnection streamConnection, javax.net.ssl.SSLEngine engine)JsseSslStreamConnection(StreamConnection connection, javax.net.ssl.SSLEngine sslEngine, boolean startTls)
-