new_fifo_channel

risingwave_batch::task::fifo_channel

Function new_fifo_channel 

Source 
pub fn new_fifo_channel(
    output_channel_size: usize,
) -> (ChanSenderImpl, Vec<ChanReceiverImpl>)