risingwave_stream::executor::exchange::permit

Function channel

source
pub fn channel(
    initial_permits: usize,
    batched_permits: usize,
    concurrent_barriers: usize,
) -> (Sender, Receiver)
Expand description

Create a channel for the exchange service.