DataPipe, DataPipeForked, IDataSinkDataAccumulator, DataProcessorBounds, DataProcessorGContactP, DataProcessorPContactG, DataProcessorWidomContactpublic abstract class DataProcessorForked extends DataProcessor implements DataPipeForked
dataInfo, dataSink, tag| Constructor | Description |
|---|---|
DataProcessorForked() |
| Modifier and Type | Method | Description |
|---|---|---|
void |
addDataSink(IDataSink newDataSink) |
Adds the given DataSink to those receiving the Data entering this DataFork,
keeping all previously entered DataSinks.
|
IDataSink |
getDataSink() |
|
IDataSink[] |
getDataSinks() |
|
void |
removeDataSink(IDataSink oldDataSink) |
Removes the specified data sink.
|
void |
setDataSink(IDataSink dataSink) |
Sets the sink receiving the data.
|
void |
setDataSinks(IDataSink[] dataSinks) |
Sets the list of DataSinks that receive the Data entering this DataFork.
|
getDataInfo, getTag, processData, processDataInfo, putData, putDataInfoputData, putDataInfopublic IDataSink getDataSink()
getDataSink in class DataProcessorpublic IDataSink[] getDataSinks()
getDataSinks in interface DataPipeForkedpublic void setDataSink(IDataSink dataSink)
DataProcessorsetDataSink in interface DataPipesetDataSink in class DataProcessordataSink - The data sink to set.public void setDataSinks(IDataSink[] dataSinks)
DataPipeForkedsetDataSinks in interface DataPipeForkeddataSinks - The data sinks to set.public void addDataSink(IDataSink newDataSink)
addDataSink in interface DataPipeForkednewDataSink - public void removeDataSink(IDataSink oldDataSink)
removeDataSink in interface DataPipeForkedoldDataSink - data sink to be removed from this list, if present.