risingwave_stream::task

Type Alias ConsumableChannelPair

source
pub type ConsumableChannelPair = (Option<Sender>, Option<Receiver>);