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, toString
public T receive()
null
if the pipe is currently empty.public boolean isClosed()
public void waitForStartSignal() throws InterruptedException
InterruptedException
Copyright © 2015–2020. All rights reserved.