channel_from_config

risingwave_stream::executor::exchange::permit

Function channel_from_config 

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