pub type LocalQueryStream = ReceiverStream<Result<DataChunk, BoxedError>>;
struct LocalQueryStream { /* private fields */ }