T - the type of elements to be sentpublic class InputPort<T> extends AbstractPort<T>
pipe, TERMINATE_ELEMENT| Constructor and Description |
|---|
InputPort()
For testing purposes only.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
isClosed() |
T |
receive() |
void |
waitForStartSignal() |
getName, getOwningStage, getPipe, getType, toStringpublic T receive()
null if the pipe is currently empty.public boolean isClosed()
public void waitForStartSignal()
throws InterruptedException
InterruptedExceptionCopyright © 2015–2020. All rights reserved.