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 IMergerStrategy
public void onPortRemoved(InputPort<?> removedInputPort)
onPortRemoved
in interface PortRemovedListener<InputPort<?>>
Copyright © 2015–2020. All rights reserved.