fn forwarding_thread( info: StoreInfo, sink: Box<dyn LogSink>, cmds_rx: Receiver<Command>, chunks: Receiver<Chunk>, on_release: Option<ArrowRecordBatchReleaseCallback>, )