Struct StreamBodyAs

pub struct StreamBodyAs<'a> { /* private fields */ }

Implementations

impl<'a> StreamBodyAs<'a>

pub fn new<S, T, FMT, E>(stream_format: FMT, stream: S) -> Self

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

Create a new StreamBodyWith providing a stream of your objects in the specified format.

pub fn with_options<S, T, FMT, E>( stream_format: FMT, stream: S, options: StreamBodyAsOptions, ) -> Self

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

pub fn headers(self, headers: HeaderMap) -> Self

pub fn header<K, V>(self, key: K, value: V) -> Self

where K: IntoHeaderName, V: Into<HeaderValue>,

impl<'a> StreamBodyAs<'a>

pub fn json_array<S, T>(stream: S) -> Self

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

pub fn json_array_with_errors<S, T, E>(stream: S) -> Self

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

pub fn json_array_with_envelope<S, T, EN>( stream: S, envelope: EN, array_field: &str, ) -> Self

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

pub fn json_array_with_envelope_errors<S, T, E, EN>( stream: S, envelope: EN, array_field: &str, ) -> Self

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<S, T>(stream: S) -> Self

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

pub fn json_nl_with_errors<S, T, E>(stream: S) -> Self

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

impl<'a> StreamBodyAs<'a>

pub fn csv<S, T>(stream: S) -> Self

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

pub fn csv_with_errors<S, T, E>(stream: S) -> Self

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

impl<'a> StreamBodyAs<'a>

pub fn text<S>(stream: S) -> Self

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

pub fn text_with_errors<S, E>(stream: S) -> Self

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

impl<'a> StreamBodyAs<'a>

pub fn protobuf<S, T>(stream: S) -> Self

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

pub fn protobuf_with_errors<S, T, E>(stream: S) -> Self

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

impl<'a> StreamBodyAs<'a>

pub fn arrow_ipc<S>(schema: SchemaRef, stream: S) -> Self

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

pub fn arrow_ipc_with_errors<S, E>(schema: SchemaRef, stream: S) -> Self

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

pub fn arrow_ipc_with_options<S>( schema: SchemaRef, stream: S, options: IpcWriteOptions, ) -> Self

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

pub fn arrow_ipc_with_options_errors<S, E>( schema: SchemaRef, stream: S, options: IpcWriteOptions, ) -> Self

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

Trait Implementations

impl<'a> Body for StreamBodyAs<'a>

type Data = Bytes

Values yielded by the Body.

type Error = Error

The error type this Body might generate.

fn poll_frame( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>>

Attempt to pull out the next data buffer of this stream.

fn is_end_stream(&self) -> bool

Returns true when the end of stream has been reached.

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the stream.

impl<'a> Debug for StreamBodyAs<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl IntoResponse for StreamBodyAs<'static>

fn into_response(self) -> Response

Create a response.