public final class RuntimeServiceFacade extends Object
Modifier and Type | Field and Description |
---|---|
static RuntimeServiceFacade |
INSTANCE |
Modifier and Type | Method and Description |
---|---|
<T> void |
connectPorts(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort)
Connects two ports with a pipe with an unlimited capacity.
|
<T> void |
connectPorts(OutputPort<? extends T> sourcePort,
InputPort<T> targetPort,
int capacity)
Connects to ports with a pipe of a certain capacity
|
void |
startWithinNewThread(AbstractStage previousStage,
AbstractStage stage)
Does not send signals.
|
public static final RuntimeServiceFacade INSTANCE
public void startWithinNewThread(AbstractStage previousStage, AbstractStage stage)
previousStage
- stage
- public <T> void connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort)
T
- the type of elements to be sentsourcePort
- OutputPort
of the sending stagetargetPort
- InputPort
of the sending stagepublic <T> void connectPorts(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity)
T
- the type of elements to be sentsourcePort
- OutputPort
of the sending stagetargetPort
- InputPort
of the sending stagecapacity
- the pipe is set to this capacity, if the value is greater than 0. If it is 0, than the pipe is unbounded, thus growing of the pipe is enabled.Copyright © 2015–2020. All rights reserved.