risingwave_stream::executor

Module stream_reader

Source

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 🔒