Trait StreamingFormat

pub trait StreamingFormat<T> {
    // Required methods
    fn to_bytes_stream<'a, 'b>(
        &'a self,
        stream: BoxStream<'b, Result<T, Error>>,
        options: &'a StreamBodyAsOptions,
    ) -> BoxStream<'b, Result<Bytes, Error>>;
    fn http_response_headers(
        &self,
        options: &StreamBodyAsOptions,
    ) -> Option<HeaderMap>;
}

Required Methods

fn to_bytes_stream<'a, 'b>( &'a self, stream: BoxStream<'b, Result<T, Error>>, options: &'a StreamBodyAsOptions, ) -> BoxStream<'b, Result<Bytes, Error>>

fn http_response_headers( &self, options: &StreamBodyAsOptions, ) -> Option<HeaderMap>

Implementors

impl StreamingFormat<String> for TextStreamFormat

impl StreamingFormat<RecordBatch> for ArrowRecordBatchIpcStreamFormat

impl<T> StreamingFormat<T> for CsvStreamFormat

where T: Serialize + Send + Sync + 'static,

impl<T> StreamingFormat<T> for JsonNewLineStreamFormat

where T: Serialize + Send + Sync + 'static,

impl<T> StreamingFormat<T> for ProtobufStreamFormat

where T: Message + Send + Sync + 'static,

impl<T, E> StreamingFormat<T> for JsonArrayStreamFormat<E>

where T: Serialize + Send + Sync + 'static, E: Serialize + Send + Sync + 'static,