pub trait BufferBuilder: Send + Sync + Any {
    // Required method
    fn build(
        &self,
        item_size: usize,
        writer_inbox: Sender<BlockMessage>,
        writer_output_id: usize
    ) -> BufferWriter;
}
Expand description

Buffer Builder

Used for connect_with_type calls.

Required Methods§

source

fn build( &self, item_size: usize, writer_inbox: Sender<BlockMessage>, writer_output_id: usize ) -> BufferWriter

Build the buffer, creating the writer

Implementors§