pub fn deserialize_stream<'a>(
input: impl Stream<Item = Result<Bytes>> + Unpin + Send + 'a,
deserializer: impl BatchDeserializer<Bytes> + 'a,
) -> BoxStream<'a, Result<RecordBatch, ArrowError>>Expand description
Deserializes a stream of bytes into a stream of RecordBatch objects using the
provided deserializer.
Returns a boxed stream of Result<RecordBatch, ArrowError>. The stream yields RecordBatch
objects as they are produced by the deserializer, or an ArrowError if an error
occurs while polling the input or deserializing.