teetime.framework.pipe

Class BoundedSynchedPipeFactory

java.lang.Object

teetime.framework.pipe.BoundedSynchedPipeFactory

All Implemented Interfaces:

IPipeFactory

public final class BoundedSynchedPipeFactory
extends Object
implements IPipeFactory

Field Summary

Fields

Modifier and Type	Field and Description
static BoundedSynchedPipeFactory	INSTANCE

Method Summary

Modifier and Type	Method and Description
<T> IPipe<T>	newPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort) Uses a default capacity of .
<T> IPipe<T>	newPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final BoundedSynchedPipeFactory INSTANCE

Method Detail

newPipe

public <T> IPipe<T> newPipe(OutputPort<? extends T> sourcePort,
                            InputPort<T> targetPort)

Uses a default capacity of .

Specified by:

newPipe in interface IPipeFactory

newPipe

public <T> IPipe<T> newPipe(OutputPort<? extends T> sourcePort,
                            InputPort<T> targetPort,
                            int capacity)

Specified by:

newPipe in interface IPipeFactory