risingwave_stream::executor::test_utils

Module mock_source

Source

Structsยง

MessageSender
A wrapper around Sender<Message>.
MockSource