Trait ArrowFrameStream 

pub trait ArrowFrameStream: Send {
    // Required method
    fn next_frame(&mut self) -> BoxFuture<'_, Option<Vec<u8>>>;
}

A pull stream of Arrow IPC byte frames, as returned by QueryService::execute_stream.

Each frame is one Arrow IPC byte chunk carried on the wire as the payload of a crate::envelope::ProtocolEnvelope (spec section 4.10); the protocol crate fixes the framing contract; the server supplies real Arrow record-batch encoding. Ok(Some(frame)) yields one chunk, Ok(None) ends the stream, and Err is terminal (the stream yields nothing further).

Required Methods

fn next_frame(&mut self) -> BoxFuture<'_, Option<Vec<u8>>>

Pulls the next frame; see the trait documentation for the contract.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl ArrowFrameStream for IntoIter<Vec<u8>>

fn next_frame(&mut self) -> BoxFuture<'_, Option<Vec<u8>>>

Implementors