Struct actix_web::dev::SizedStream [−][src]
pub struct SizedStream<S> { /* fields omitted */ }
Expand description
Known sized streaming response wrapper.
This body implementation should be used if total size of stream is known. Data is sent as-is without using chunked transfer encoding.
Implementations
Trait Implementations
Performs the conversion.
impl<S, E> MessageBody for SizedStream<S> where
E: Into<Box<dyn Error + 'static, Global>> + 'static,
S: Stream<Item = Result<Bytes, E>>,
impl<S, E> MessageBody for SizedStream<S> where
E: Into<Box<dyn Error + 'static, Global>> + 'static,
S: Stream<Item = Result<Bytes, E>>,
pub fn poll_next(
self: Pin<&mut SizedStream<S>>,
cx: &mut Context<'_>
) -> Poll<Option<Result<Bytes, <SizedStream<S> as MessageBody>::Error>>>
pub fn poll_next(
self: Pin<&mut SizedStream<S>>,
cx: &mut Context<'_>
) -> Poll<Option<Result<Bytes, <SizedStream<S> as MessageBody>::Error>>>
Attempts to pull out the next value of the underlying Stream
.
Empty values are skipped to prevent SizedStream
’s transmission being
ended on a zero-length chunk, but rather proceed until the underlying
Stream
ends.
type Error = E
Auto Trait Implementations
impl<S> RefUnwindSafe for SizedStream<S> where
S: RefUnwindSafe,
impl<S> Send for SizedStream<S> where
S: Send,
impl<S> Sync for SizedStream<S> where
S: Sync,
impl<S> UnwindSafe for SizedStream<S> where
S: UnwindSafe,