- java.lang.Object
-
- org.xnio.channels.AssembledChannel
-
- org.xnio.channels.AssembledConnectedChannel
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,java.nio.channels.Channel
,java.nio.channels.InterruptibleChannel
,BoundChannel
,CloseableChannel
,Configurable
,ConnectedChannel
- Direct Known Subclasses:
AssembledSslChannel
public class AssembledConnectedChannel extends AssembledChannel implements ConnectedChannel
A closeable, connected view over a read and write side of a suspendable channel, at least one of which is connected.- Author:
- David M. Lloyd
-
-
Field Summary
-
Fields inherited from interface org.xnio.channels.Configurable
EMPTY
-
-
Constructor Summary
Constructors Constructor Description AssembledConnectedChannel(SuspendableReadChannel readChannel, SuspendableWriteChannel writeChannel)
Construct a new instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ChannelListener.Setter<? extends AssembledConnectedChannel>
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>
AgetLocalAddress(java.lang.Class<A> type)
Get the local address of a given type, ornull
if the address is not of that type.java.net.SocketAddress
getPeerAddress()
Get the peer address of this channel.<A extends java.net.SocketAddress>
AgetPeerAddress(java.lang.Class<A> type)
Get the peer address of a given type, ornull
if the address is not of that type.-
Methods inherited from class org.xnio.channels.AssembledChannel
close, getIoThread, getOption, getWorker, isOpen, setOption, supportsOption
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.xnio.channels.CloseableChannel
close, getIoThread, getWorker
-
Methods inherited from interface org.xnio.channels.Configurable
getOption, setOption, supportsOption
-
-
-
-
Constructor Detail
-
AssembledConnectedChannel
public AssembledConnectedChannel(SuspendableReadChannel readChannel, SuspendableWriteChannel writeChannel)
Construct a new instance. At least one of the channels must be an instance ofConnectedChannel
.- Parameters:
readChannel
- the read channelwriteChannel
- the write channel
-
-
Method Detail
-
getCloseSetter
public ChannelListener.Setter<? extends AssembledConnectedChannel> getCloseSetter()
Description copied from interface:CloseableChannel
Get the setter which can be used to change the close listener for this channel. If the channel is already closed, then the listener will not be called.- Specified by:
getCloseSetter
in interfaceBoundChannel
- Specified by:
getCloseSetter
in interfaceCloseableChannel
- Specified by:
getCloseSetter
in interfaceConnectedChannel
- Overrides:
getCloseSetter
in classAssembledChannel
- Returns:
- the setter
-
getPeerAddress
public java.net.SocketAddress getPeerAddress()
Description copied from interface:ConnectedChannel
Get the peer address of this channel.- Specified by:
getPeerAddress
in interfaceConnectedChannel
- Returns:
- the peer address
-
getPeerAddress
public <A extends java.net.SocketAddress> A getPeerAddress(java.lang.Class<A> type)
Description copied from interface:ConnectedChannel
Get the peer address of a given type, ornull
if the address is not of that type.- Specified by:
getPeerAddress
in interfaceConnectedChannel
- Parameters:
type
- the address type class- Returns:
- the peer address, or
null
if unknown
-
getLocalAddress
public java.net.SocketAddress getLocalAddress()
Description copied from interface:BoundChannel
Get the local address that this channel is bound to.- Specified by:
getLocalAddress
in interfaceBoundChannel
- Returns:
- the local address
-
getLocalAddress
public <A extends java.net.SocketAddress> A getLocalAddress(java.lang.Class<A> type)
Description copied from interface:BoundChannel
Get the local address of a given type, ornull
if the address is not of that type.- Specified by:
getLocalAddress
in interfaceBoundChannel
- Type Parameters:
A
- the address type- Parameters:
type
- the address type class- Returns:
- the local address, or
null
if unknown
-
-