Skip to main content

Module stream

vmbus_channel

Module stream 

Source
Expand description

Stream combinators shared across the vmbus channel/client stack.

Structsยง

TaggedStream
A [futures::Stream] adapter that tags each item produced by the inner stream with a caller-supplied T. Yields (tag, Some(item)) for each inner item, then a single (tag, None) sentinel when the inner stream ends, and None thereafter.