risingwave_stream::executor

Module receiver

source

Structsยง

  • ReceiverExecutor
    ReceiverExecutor is used along with a channel. After creating a mpsc channel, there should be a ReceiverExecutor running in the background, so as to push messages down to the executors.