Struct ajars_actix_web::actix_web::body::BodyStream [−]
pub struct BodyStream<S> { /* fields omitted */ }
Expand description
Streaming response wrapper.
Response does not contain Content-Length
header and appropriate transfer encoding is used.
Implementations
pub fn new(stream: S) -> BodyStream<S>
Trait Implementations
pub fn from(s: BodyStream<S>) -> AnyBody
pub fn from(s: BodyStream<S>) -> AnyBody
Performs the conversion.
impl<S, E> MessageBody for BodyStream<S> where
E: Into<Box<dyn Error + 'static, Global>> + 'static,
S: Stream<Item = Result<Bytes, E>>,
impl<S, E> MessageBody for BodyStream<S> where
E: Into<Box<dyn Error + 'static, Global>> + 'static,
S: Stream<Item = Result<Bytes, E>>,
pub fn poll_next(
self: Pin<&mut BodyStream<S>>,
cx: &mut Context<'_>
) -> Poll<Option<Result<Bytes, <BodyStream<S> as MessageBody>::Error>>>
pub fn poll_next(
self: Pin<&mut BodyStream<S>>,
cx: &mut Context<'_>
) -> Poll<Option<Result<Bytes, <BodyStream<S> as MessageBody>::Error>>>
Attempts to pull out the next value of the underlying [Stream
].
Empty values are skipped to prevent BodyStream
’s transmission being
ended on a zero-length chunk, but rather proceed until the underlying
[Stream
] ends.