public class AssembledConnectedStreamChannel extends AssembledStreamChannel implements ConnectedStreamChannel
EMPTY| Constructor and Description |
|---|
AssembledConnectedStreamChannel(ConnectedChannel connection,
StreamSourceChannel source,
StreamSinkChannel sink)
Construct a new instance.
|
AssembledConnectedStreamChannel(StreamSourceChannel source,
StreamSinkChannel sink)
Construct a new instance.
|
| Modifier and Type | Method and Description |
|---|---|
ChannelListener.Setter<? extends AssembledConnectedStreamChannel> |
getCloseSetter()
Get the setter which can be used to change the close listener for this channel.
|
java.net.SocketAddress |
getLocalAddress()
Get the local address that this channel is bound to.
|
<A extends java.net.SocketAddress> |
getLocalAddress(java.lang.Class<A> type)
Get the local address of a given type, or
null if the address is not of that
type. |
java.net.SocketAddress |
getPeerAddress()
Get the peer address of this channel.
|
<A extends java.net.SocketAddress> |
getPeerAddress(java.lang.Class<A> type)
Get the peer address of a given type, or
null if the address is not of that
type. |
ChannelListener.Setter<? extends AssembledConnectedStreamChannel> |
getReadSetter()
Get the setter which can be used to change the read listener for this channel.
|
ChannelListener.Setter<? extends AssembledConnectedStreamChannel> |
getWriteSetter()
Get the setter which can be used to change the write listener for this channel.
|
awaitReadable, awaitReadable, awaitWritable, awaitWritable, close, flush, getIoThread, getOption, getReadThread, getWorker, getWriteThread, isOpen, isReadResumed, isWriteResumed, read, read, read, resumeReads, resumeWrites, setOption, shutdownReads, shutdownWrites, supportsOption, suspendReads, suspendWrites, transferFrom, transferFrom, transferTo, transferTo, wakeupReads, wakeupWrites, write, write, write, writeFinal, writeFinal, writeFinalclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waittransferFrom, transferFrom, writeFinal, writeFinal, writeFinalawaitWritable, awaitWritable, close, flush, getWriteThread, isOpen, isWriteResumed, resumeWrites, shutdownWrites, suspendWrites, wakeupWritestransferTo, transferToawaitReadable, awaitReadable, getReadThread, isReadResumed, resumeReads, shutdownReads, suspendReads, wakeupReadsgetIoThread, getWorkergetOption, setOption, supportsOptionpublic AssembledConnectedStreamChannel(ConnectedChannel connection, StreamSourceChannel source, StreamSinkChannel sink)
connection - the connected channelsource - the sourcesink - the sinkpublic AssembledConnectedStreamChannel(StreamSourceChannel source, StreamSinkChannel sink)
source - the sourcesink - the sinkpublic ChannelListener.Setter<? extends AssembledConnectedStreamChannel> getCloseSetter()
StreamChannelgetCloseSetter in interface BoundChannelgetCloseSetter in interface CloseableChannelgetCloseSetter in interface ConnectedChannelgetCloseSetter in interface ConnectedStreamChannelgetCloseSetter in interface StreamChannelgetCloseSetter in interface StreamSinkChannelgetCloseSetter in interface StreamSourceChannelgetCloseSetter in interface SuspendableChannelgetCloseSetter in interface SuspendableReadChannelgetCloseSetter in interface SuspendableWriteChannelgetCloseSetter in class AssembledStreamChannelpublic ChannelListener.Setter<? extends AssembledConnectedStreamChannel> getReadSetter()
StreamChannelgetReadSetter in interface ConnectedStreamChannelgetReadSetter in interface StreamChannelgetReadSetter in interface StreamSourceChannelgetReadSetter in interface SuspendableChannelgetReadSetter in interface SuspendableReadChannelgetReadSetter in class AssembledStreamChannelpublic ChannelListener.Setter<? extends AssembledConnectedStreamChannel> getWriteSetter()
StreamChannelgetWriteSetter in interface ConnectedStreamChannelgetWriteSetter in interface StreamChannelgetWriteSetter in interface StreamSinkChannelgetWriteSetter in interface SuspendableChannelgetWriteSetter in interface SuspendableWriteChannelgetWriteSetter in class AssembledStreamChannelpublic java.net.SocketAddress getPeerAddress()
ConnectedChannelgetPeerAddress in interface ConnectedChannelpublic <A extends java.net.SocketAddress> A getPeerAddress(java.lang.Class<A> type)
ConnectedChannelnull if the address is not of that
type.getPeerAddress in interface ConnectedChanneltype - the address type classnull if unknownpublic java.net.SocketAddress getLocalAddress()
BoundChannelgetLocalAddress in interface BoundChannelpublic <A extends java.net.SocketAddress> A getLocalAddress(java.lang.Class<A> type)
BoundChannelnull if the address is not of that
type.getLocalAddress in interface BoundChannelA - the address typetype - the address type classnull if unknownCopyright © 2016 JBoss, a division of Red Hat, Inc.