I have this case where I am trying to build a pipeline using TPL dataflow that could process a big number of items. At some point in the pipeline I need to batch items and send to the next block after they are processed.