pub async fn stream_partition_async( tx: Sender<LogMsg>, uri: DatasetDataUri, on_cmd: Box<dyn Fn(Command) + Sync + Send>, on_msg: Option<Box<dyn Fn() + Sync + Send>>, ) -> Result<(), StreamError>