Struct StreamBodyAsOptions

pub struct StreamBodyAsOptions {
    pub buffering_ready_items: Option<usize>,
    pub buffering_bytes: Option<usize>,
    pub content_type: Option<HttpHeaderValue>,
}

Fields

buffering_ready_items: Option<usize>

buffering_bytes: Option<usize>

content_type: Option<HttpHeaderValue>

Implementations

impl StreamBodyAsOptions

pub fn new() -> Self

pub fn buffering_ready_items(self, ready_items: usize) -> Self

pub fn buffering_bytes(self, ready_bytes: usize) -> Self

pub fn content_type(self, content_type: HttpHeaderValue) -> Self

impl StreamBodyAsOptions

pub fn json_array<'a, S, T>(self, stream: S) -> StreamBodyAs<'a>

where T: Serialize + Send + Sync + 'static, S: Stream<Item = T> + 'a + Send,

pub fn json_array_with_errors<'a, S, T, E>(self, stream: S) -> StreamBodyAs<'a>

where T: Serialize + Send + Sync + 'static, S: Stream<Item = Result<T, E>> + 'a + Send, E: Into<Error>,

pub fn json_array_with_envelope<'a, S, T, EN>( self, stream: S, envelope: EN, array_field: &str, ) -> StreamBodyAs<'a>

where T: Serialize + Send + Sync + 'static, S: Stream<Item = T> + 'a + Send, EN: Serialize + Send + Sync + 'static,

pub fn json_array_with_envelope_errors<'a, S, T, E, EN>( self, stream: S, envelope: EN, array_field: &str, ) -> StreamBodyAs<'a>

where T: Serialize + Send + Sync + 'static, S: Stream<Item = Result<T, E>> + 'a + Send, E: Into<Error>, EN: Serialize + Send + Sync + 'static,

pub fn json_nl<'a, S, T>(self, stream: S) -> StreamBodyAs<'a>

where T: Serialize + Send + Sync + 'static, S: Stream<Item = T> + 'a + Send,

pub fn json_nl_with_errors<'a, S, T, E>(self, stream: S) -> StreamBodyAs<'a>

where T: Serialize + Send + Sync + 'static, S: Stream<Item = Result<T, E>> + 'a + Send, E: Into<Error>,

impl StreamBodyAsOptions

pub fn csv<'a, S, T>(self, stream: S) -> StreamBodyAs<'a>

where T: Serialize + Send + Sync + 'static, S: Stream<Item = T> + 'a + Send,

pub fn csv_with_errors<'a, S, T, E>(self, stream: S) -> StreamBodyAs<'a>

where T: Serialize + Send + Sync + 'static, S: Stream<Item = Result<T, E>> + 'a + Send, E: Into<Error> + 'static,

impl StreamBodyAsOptions

pub fn text<'a, S>(self, stream: S) -> StreamBodyAs<'a>

where S: Stream<Item = String> + 'a + Send,

pub fn text_with_errors<'a, S, E>(self, stream: S) -> StreamBodyAs<'a>

where S: Stream<Item = Result<String, E>> + 'a + Send, E: Into<Error>,

impl StreamBodyAsOptions

pub fn protobuf<'a, S, T>(self, stream: S) -> StreamBodyAs<'a>

where T: Message + Send + Sync + 'static, S: Stream<Item = T> + 'a + Send,

pub fn protobuf_with_errors<'a, S, T, E>(self, stream: S) -> StreamBodyAs<'a>

where T: Message + Send + Sync + 'static, S: Stream<Item = Result<T, E>> + 'a + Send, E: Into<Error>,

impl StreamBodyAsOptions

pub fn arrow_ipc<'a, S>(self, schema: SchemaRef, stream: S) -> StreamBodyAs<'a>

where S: Stream<Item = RecordBatch> + 'a + Send,

pub fn arrow_ipc_with_errors<'a, S, E>( self, schema: SchemaRef, stream: S, ) -> StreamBodyAs<'a>

where S: Stream<Item = Result<RecordBatch, E>> + 'a + Send, E: Into<Error>,

pub fn arrow_ipc_with_options<'a, S>( self, schema: SchemaRef, stream: S, options: IpcWriteOptions, ) -> StreamBodyAs<'a>

where S: Stream<Item = RecordBatch> + 'a + Send,

pub fn arrow_ipc_with_options_errors<'a, S, E>( self, schema: SchemaRef, stream: S, options: IpcWriteOptions, ) -> StreamBodyAs<'a>

where S: Stream<Item = Result<RecordBatch, E>> + 'a + Send, E: Into<Error>,