Class MemoryEndPointPipe

java.lang.Object

org.eclipse.jetty.io.MemoryEndPointPipe

All Implemented Interfaces:

EndPoint.Pipe

public class MemoryEndPointPipe
extends Object
implements EndPoint.Pipe

Memory-based implementation of EndPoint.Pipe.

Constructor Summary

Constructors

Constructor	Description
MemoryEndPointPipe(Scheduler scheduler, Consumer<Invocable.Task> consumer, SocketAddress socketAddress)

Method Summary

Modifier and Type	Method	Description
EndPoint	getLocalEndPoint()
EndPoint	getRemoteEndPoint()
void	setLocalEndPointMaxCapacity(int maxCapacity)
void	setRemoteEndPointMaxCapacity(int maxCapacity)

Methods inherited from class Object

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

Constructor Details

MemoryEndPointPipe

public MemoryEndPointPipe(Scheduler scheduler,
 Consumer<Invocable.Task> consumer,
 SocketAddress socketAddress)

Method Details

getLocalEndPoint

public EndPoint getLocalEndPoint()

Specified by:

getLocalEndPoint in interface EndPoint.Pipe

Returns:

the EndPoint of the local peer

getRemoteEndPoint

public EndPoint getRemoteEndPoint()

Specified by:

getRemoteEndPoint in interface EndPoint.Pipe

Returns:

the EndPoint of the remote peer

setLocalEndPointMaxCapacity

public void setLocalEndPointMaxCapacity(int maxCapacity)

setRemoteEndPointMaxCapacity

public void setRemoteEndPointMaxCapacity(int maxCapacity)