risingwave_stream::executor::exchange::permit

Function channel_from_config

Source 
pub fn channel_from_config(config: &StreamingConfig) -> (Sender, Receiver)