T - the type of the elements which this pipe should transfer.AbstractUnsynchedPipe instead.@Deprecated public abstract class AbstractUnsynchedPipe<T> extends AbstractPipe<T>
cachedTargetStage| Modifier | Constructor and Description | 
|---|---|
| protected  | AbstractUnsynchedPipe(OutputPort<? extends T> sourcePort,
                     InputPort<T> targetPort)Deprecated.  | 
| Modifier and Type | Method and Description | 
|---|---|
| void | close()Deprecated.  May only be invoked by the input port and the owning (target) stage. | 
| boolean | isClosed()Deprecated.  | 
| void | reportNewElement()Deprecated.  Stages report new elements with this method. | 
| void | sendSignal(ISignal signal)Deprecated.  A stage can pass on a signal by executing this method. | 
| void | waitForStartSignal()Deprecated.  | 
getCachedTargetStage, getScheduler, getSourcePort, getTargetPort, hasMore, setScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitadd, addNonBlocking, capacity, isEmpty, removeLast, sizeprotected AbstractUnsynchedPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort)
public final void sendSignal(ISignal signal)
IPipesignal - The signal which needs to be passed on.public final void reportNewElement()
IPipepublic boolean isClosed()
true if the pipe is closed, that is, if the pipe is empty and if the source stage will not send any elements anymore (because the
         stage has finished its whole work);
         returns false in all other cases.public void close()
IPipepublic void waitForStartSignal()
                        throws InterruptedException
InterruptedExceptionCopyright © 2015–2020. All rights reserved.