Internals of streamDiscard

The streamDiscard module works as a sink of stream(s). It basically reads all inputs and discard them. Users can use streamOneToN’s TagSelectT option to route data to this module to do dynamic data removal.

Three variants have been implemented, handling normal stream or synchronized streams.

discarding a singe stream structure discarding streams structure discarding streams sharing end-flag structure

The code implementation is a simple while loop.