risingwave_stream::executor::exchange::permit

Function channel_for_test

Source 
pub fn channel_for_test() -> (Sender, Receiver)