channel_for_test

risingwave_stream::executor::exchange::permit

Function channel_for_test 

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