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.void
StreamConnection. 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 void
Messages_$logger. connectionNotifyReadClosedFailed(java.lang.Throwable cause, StreamConnection connection)
void
Messages. connectionNotifyReadClosedFailed(java.lang.Throwable cause, StreamConnection connection)
void
Messages_$logger. connectionNotifyWriteClosedFailed(java.lang.Throwable cause, StreamConnection connection)
void
Messages. 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 class
JsseSslConnection
class
JsseSslStreamConnection
StreamConnection with SSL support.class
SslConnection
A 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)
-