public class BlockingBusyWaitingRoundRobinMergerStrategy extends Object implements IMergerStrategy
| Constructor and Description |
|---|
BlockingBusyWaitingRoundRobinMergerStrategy() |
| Modifier and Type | Method and Description |
|---|---|
<T> T |
getNextInput(Merger<T> merger) |
void |
onPortRemoved(InputPort<?> removedInputPort) |
public BlockingBusyWaitingRoundRobinMergerStrategy()
public <T> T getNextInput(Merger<T> merger)
getNextInput in interface IMergerStrategypublic void onPortRemoved(InputPort<?> removedInputPort)
onPortRemoved in interface PortRemovedListener<InputPort<?>>Copyright © 2015–2020. All rights reserved.