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.
|
SocketAddress |
getLocalAddress()
Get the local address that this channel is bound to.
|
<A extends SocketAddress> |
getLocalAddress(Class<A> type)
Get the local address of a given type, or
null if the address is not of that
type. |
SocketAddress |
getPeerAddress()
Get the peer address of this channel.
|
<A extends SocketAddress> |
getPeerAddress(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, supportsOptionwrite, writewriteread, readreadpublic 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 SocketAddress getPeerAddress()
ConnectedChannelgetPeerAddress in interface ConnectedChannelpublic <A extends SocketAddress> A getPeerAddress(Class<A> type)
ConnectedChannelnull if the address is not of that
type.getPeerAddress in interface ConnectedChanneltype - the address type classnull if unknownpublic SocketAddress getLocalAddress()
BoundChannelgetLocalAddress in interface BoundChannelpublic <A extends SocketAddress> A getLocalAddress(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 © 2021 JBoss by Red Hat. All rights reserved.