Module stream_reader

Modules

• stream_reader_with_pause 🔒

Structs

• StreamReaderWithPause 🔒
  StreamReaderWithPause merges two streams, with one receiving barriers (and maybe other types of messages) and the other receiving data only (no barrier). The merged stream can be paused (StreamReaderWithPause::pause_stream) and resumed (StreamReaderWithPause::resume_stream). A paused stream will not receive any data from either original stream until a barrier arrives and the stream is resumed.

Type Aliases

• ExecutorMessageStream 🔒
• ReaderArm 🔒
• StreamReaderData 🔒