type FutureStream = Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send>>;
struct FutureStream {}