XNIO API 3.8.13.Final · org.xnio.StreamConnection · APIdia, the JavaDoc alternative

Modifier and Type	Field and Description
private AtomicReference<ChannelListener<? super StreamConnection>>	closeListener
private static final ChannelListener<? super StreamConnection>	INVOKED_CLOSE_LISTENER_FLAG An empty listener used as a flag, to indicate that close listener has been invoked.
private static final Logger	log
private ConduitStreamSinkChannel	sinkChannel
private ConduitStreamSourceChannel	sourceChannel

Access	Constructor and Description
protected	StreamConnection(final XnioIoThread the I/O thread thread) Construct a new instance.

Method Summary

Modifier and Type	Method and Description
public ChannelListener<? super StreamConnection>	getCloseListener() Implements org.xnio.channels.CloseListenerSettable.getCloseListener. Get the close listener.
public ChannelListener.Setter<? extends StreamConnection>	getCloseSetter() Implements org.xnio.channels.CloseableChannel.getCloseSetter, org.xnio.channels.ConnectedChannel.getCloseSetter. Get the setter which can be used to change the close listener for this channel.
public ConduitStreamSinkChannel	Returns: the sink channel getSinkChannel() Get the sink channel.
public ConduitStreamSourceChannel	Returns: the source channel getSourceChannel() Get the source channel.
pack-priv void	invokeCloseListener() Implements abstract org.xnio.Connection.invokeCloseListener.
private final ChannelListener<? super StreamConnection>	mergeListeners(final ChannelListener<? super StreamConnection> listener1, final ChannelListener<? super StreamConnection> listener2)
protected void	notifyReadClosed() Implements abstract org.xnio.Connection.notifyReadClosed. Indicate to conduit handlers that reads have been closed.
protected void	notifyWriteClosed() Implements abstract org.xnio.Connection.notifyWriteClosed. Indicate to conduit handlers that writes have been closed.
private static <T> T	notNull(T orig)
public void	setCloseListener(final ChannelListener<? super StreamConnection> the close listener listener) Implements org.xnio.channels.CloseListenerSettable.setCloseListener. Set the close listener.
protected void	setSinkConduit(StreamSinkConduit the sink conduit for this channel conduit) Set the sink conduit for this channel.
protected void	setSourceConduit(StreamSourceConduit the source conduit for this channel conduit) Set the source conduit for this channel.

Inherited from org.xnio.Connection:: close closeAction getIoThread getLocalAddress getOption getPeerAddress getWorker isOpen isReadShutdown isWriteShutdown readClosed setOption supportsOption writeClosed

closeListener	back to summary
private AtomicReference<ChannelListener<? super StreamConnection>> closeListener

INVOKED_CLOSE_LISTENER_FLAG	back to summary
private static final ChannelListener<? super StreamConnection> INVOKED_CLOSE_LISTENER_FLAG An empty listener used as a flag, to indicate that close listener has been invoked.

log	back to summary
private static final Logger log

sinkChannel	back to summary
private ConduitStreamSinkChannel sinkChannel

sourceChannel	back to summary
private ConduitStreamSourceChannel sourceChannel

StreamConnection	back to summary
protected StreamConnection(final XnioIoThread thread) Construct a new instance. Parameters thread:XnioIoThread the I/O thread

Method Detail

getCloseListener	back to summary
public ChannelListener<? super StreamConnection> getCloseListener() Implements org.xnio.channels.CloseListenerSettable.getCloseListener. Doc from org.xnio.channels.CloseListenerSettable.getCloseListener. Get the close listener. Returns:ChannelListener<? super StreamConnection> the close listener

getCloseListener

back to summary

public ChannelListener<? super StreamConnection> getCloseListener()

Implements org.xnio.channels.CloseListenerSettable.getCloseListener.

Doc from org.xnio.channels.CloseListenerSettable.getCloseListener.

Get the close listener.

Returns:ChannelListener<? super StreamConnection>: the close listener

getCloseSetter	back to summary
public ChannelListener.Setter<? extends StreamConnection> getCloseSetter() Implements org.xnio.channels.CloseableChannel.getCloseSetter, org.xnio.channels.ConnectedChannel.getCloseSetter. Doc from org.xnio.channels.CloseableChannel.getCloseSetter. 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. Returns:ChannelListener.Setter<? extends StreamConnection> the setter

getCloseSetter

back to summary

public ChannelListener.Setter<? extends StreamConnection> getCloseSetter()

Implements org.xnio.channels.CloseableChannel.getCloseSetter, org.xnio.channels.ConnectedChannel.getCloseSetter.

Doc from org.xnio.channels.CloseableChannel.getCloseSetter.

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.

Returns:ChannelListener.Setter<? extends StreamConnection>: the setter

getSinkChannel	back to summary
public ConduitStreamSinkChannel getSinkChannel() Get the sink channel. Returns:ConduitStreamSinkChannel the sink channel

getSinkChannel

back to summary

public ConduitStreamSinkChannel getSinkChannel()

Get the sink channel.

Returns:ConduitStreamSinkChannel: the sink channel

getSourceChannel	back to summary
public ConduitStreamSourceChannel getSourceChannel() Get the source channel. Returns:ConduitStreamSourceChannel the source channel

getSourceChannel

back to summary

public ConduitStreamSourceChannel getSourceChannel()

Get the source channel.

Returns:ConduitStreamSourceChannel: the source channel

invokeCloseListener	back to summary
pack-priv void invokeCloseListener() Implements abstract org.xnio.Connection.invokeCloseListener.

mergeListeners	back to summary
private final ChannelListener<? super StreamConnection> mergeListeners(final ChannelListener<? super StreamConnection> listener1, final ChannelListener<? super StreamConnection> listener2)

notifyReadClosed	back to summary
protected void notifyReadClosed() Implements abstract org.xnio.Connection.notifyReadClosed. Doc from org.xnio.Connection.notifyReadClosed. Indicate to conduit handlers that reads have been closed. Annotations @Override

notifyReadClosed

back to summary

protected void notifyReadClosed()

Implements abstract org.xnio.Connection.notifyReadClosed.

Doc from org.xnio.Connection.notifyReadClosed.

Indicate to conduit handlers that reads have been closed.

Annotations

@Override

notifyWriteClosed	back to summary
protected void notifyWriteClosed() Implements abstract org.xnio.Connection.notifyWriteClosed. Doc from org.xnio.Connection.notifyWriteClosed. Indicate to conduit handlers that writes have been closed. Annotations @Override

notifyWriteClosed

back to summary

protected void notifyWriteClosed()

Implements abstract org.xnio.Connection.notifyWriteClosed.

Doc from org.xnio.Connection.notifyWriteClosed.

Indicate to conduit handlers that writes have been closed.

Annotations

@Override

notNull	back to summary
private static <T> T notNull(T orig) throws IllegalStateException

setCloseListener	back to summary
public void setCloseListener(final ChannelListener<? super StreamConnection> listener) Implements org.xnio.channels.CloseListenerSettable.setCloseListener. Doc from org.xnio.channels.CloseListenerSettable.setCloseListener. Set the close listener. Parameters listener:ChannelListener<? super StreamConnection> the close listener

setCloseListener

back to summary

public void setCloseListener(final ChannelListener<? super StreamConnection> listener)

Implements org.xnio.channels.CloseListenerSettable.setCloseListener.

Doc from org.xnio.channels.CloseListenerSettable.setCloseListener.

Set the close listener.

Parameters

listener:ChannelListener<? super StreamConnection>: the close listener

setSinkConduit	back to summary
protected void setSinkConduit(StreamSinkConduit conduit) Set the sink conduit for this channel. The sink channel will automatically be updated. Parameters conduit:StreamSinkConduit the sink conduit for this channel

setSinkConduit

back to summary

protected void setSinkConduit(StreamSinkConduit conduit)

Set the sink conduit for this channel. The sink channel will automatically be updated.

Parameters

conduit:StreamSinkConduit: the sink conduit for this channel

setSourceConduit	back to summary
protected void setSourceConduit(StreamSourceConduit conduit) Set the source conduit for this channel. The source channel will automatically be updated. Parameters conduit:StreamSourceConduit the source conduit for this channel

setSourceConduit

back to summary

protected void setSourceConduit(StreamSourceConduit conduit)

Set the source conduit for this channel. The source channel will automatically be updated.

Parameters

conduit:StreamSourceConduit: the source conduit for this channel

public abstract Class StreamConnection

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail