Function deserialize_stream

pub fn deserialize_stream<'a>(
    input: impl Stream<Item = Result<Bytes>> + Unpin + Send + 'a,
    deserializer: impl BatchDeserializer<Bytes> + 'a,
) -> BoxStream<'a, Result<RecordBatch, ArrowError>>

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.