risingwave_stream::executor

Module subtask

source

Structs§

  • The thin wrapper for subtask-wrapped executor, containing a channel to receive the messages from the subtask.

Functions§

  • Wrap an executor into a subtask and a thin receiver executor, connected by a channel with a buffer size of 1.

Type Aliases§