Package org.webpieces.asyncserver.impl

Class ProxyDataListener

java.lang.Object

org.webpieces.asyncserver.impl.ProxyDataListener

All Implemented Interfaces:

org.webpieces.nio.api.handlers.DataListener

public class ProxyDataListener
extends java.lang.Object
implements org.webpieces.nio.api.handlers.DataListener

Constructor Summary

Constructors

Constructor	Description
ProxyDataListener(ConnectedChannels connectedChannels, AsyncDataListener dataListener)

Method Summary

Modifier and Type	Method	Description
void	connectionOpened(org.webpieces.nio.api.channels.Channel channel, boolean isReadyForWrites)
void	failure(org.webpieces.nio.api.channels.Channel channel, java.nio.ByteBuffer data, java.lang.Exception e)
void	farEndClosed(org.webpieces.nio.api.channels.Channel channel)
java.util.concurrent.CompletableFuture<java.lang.Void>	incomingData(org.webpieces.nio.api.channels.Channel channel, java.nio.ByteBuffer b)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProxyDataListener

public ProxyDataListener(ConnectedChannels connectedChannels,
                         AsyncDataListener dataListener)

Method Detail

incomingData

public java.util.concurrent.CompletableFuture<java.lang.Void> incomingData(org.webpieces.nio.api.channels.Channel channel,
                                                                           java.nio.ByteBuffer b)

Specified by:

incomingData in interface org.webpieces.nio.api.handlers.DataListener

farEndClosed

public void farEndClosed(org.webpieces.nio.api.channels.Channel channel)

Specified by:

farEndClosed in interface org.webpieces.nio.api.handlers.DataListener

failure

public void failure(org.webpieces.nio.api.channels.Channel channel,
                    java.nio.ByteBuffer data,
                    java.lang.Exception e)

Specified by:

failure in interface org.webpieces.nio.api.handlers.DataListener

connectionOpened

public void connectionOpened(org.webpieces.nio.api.channels.Channel channel,
                             boolean isReadyForWrites)