pub type BoxChunkSourceStream = BoxStream<'static, ConnectorResult<StreamChunk>>;
struct BoxChunkSourceStream {}