pub fn channel(
capacity: usize,
when_full: WhenFull,
component_id: String,
) -> (BufferSender, BufferReceiver)Expand description
Creates a new memory buffer with the given capacity (in batches).
pub fn channel(
capacity: usize,
when_full: WhenFull,
component_id: String,
) -> (BufferSender, BufferReceiver)Creates a new memory buffer with the given capacity (in batches).