Module archivist_lib::logs::multiplex

Structs

• Multiplexer
  A Multiplexer takes multiple possibly-ordered streams and attempts to impose a sensible ordering over the yielded items without risking starvation. New streams can be added to the multiplexer by sending them on a channel.
• MultiplexerHandle
  A handle to a running multiplexer. Can be used to add new sub-streams to the multiplexer.
• SubStream
  A SubStream wraps an inner stream and keeps its latest value cached inline for comparison with the cached values of other SubStreams, allowing for semi-ordered merging of streams.

Traits

• DebugStream

Type Aliases

• PinStream