One value being processed by a consumer. On receipt of a bite, every consumer
must either call next or unsubscribe, to allow the further items to
arrive (to other subscribers). Therefore, a consumable always flows at the
pace of he slowest consumer.
When piping a consumable, it's essential to call done() for every item
which does not make it to the output, for example due to a filter or reduce.
One value being processed by a consumer. On receipt of a bite, every consumer must either call next or unsubscribe, to allow the further items to arrive (to other subscribers). Therefore, a consumable always flows at the pace of he slowest consumer.
When piping a consumable, it's essential to call done() for every item which does not make it to the output, for example due to a filter or reduce.
Consumable