Module counting_streams 

A facility for an MPSC channel that counts the number of outstanding entries on the channel.

Structs

CountingSink

A wrapper around an arbitrary Sink, to count the items inserted.

CountingStream

A wrapper around an arbitrary Stream, to count the items inserted.

Functions

channel

Wrap a Sink/Stream pair into a CountingSink and CountingStream pair.