Function batching_thread

fn batching_thread(
    config: ChunkBatcherConfig,
    rx_cmd: Receiver<Command>,
    tx_chunk: Sender<Chunk>,
)