Struct Stream 

pub struct Stream<S>
where
    S: Future<Output = Option<Shared>> + 'static,
{ /* private fields */ }

Implementations

impl<S> Stream<S>

where S: Future<Output = Option<Shared>> + 'static,

pub fn new(stream: S) -> Self

pub fn header(self, name: &[u8], value: &[u8]) -> Self

pub fn write_head_stream( self, out: &mut [u8], date: &[u8; 29], ) -> Option<(usize, S)>

impl<II> Stream<IterStream<II>>

where II: Iterator<Item = Shared> + Unpin + 'static,

pub fn from_chunks<I>(iter: I) -> Self

where I: IntoIterator<Item = Shared, IntoIter = II>,

Trait Implementations

impl<S> IntoServeResponse<'static> for Stream<S>

where S: Future<Output = Option<Shared>> + 'static,

fn into_serve_response(self) -> ServeInner<'static>

impl<'req, S> Shape<'req> for Stream<S>

where S: Future<Output = Option<Shared>> + 'static,

type StreamInner = S

fn write_head_stream( self, out: &mut [u8], date: &[u8; 29], ) -> Option<(usize, S)>

fn write_into_slice(&self, out: &mut [u8], date: &[u8; 29]) -> Option<usize>

fn preserialize(&self) -> (Vec<u8>, usize)

fn write_head_only( &self, out: &mut [u8], date: &[u8; 29], ) -> Option<(usize, &'static [u8])>

fn write_head_split( self, out: &mut [u8], date: &[u8; 29], ) -> Option<(usize, Shared)>

fn preserialize_static(&self) -> Option<(Vec<u8>, usize, &'static [u8])>

fn body_for_gzip(&self) -> Option<&[u8]>

fn apply_gzip_body(&mut self, _compressed: Shared)

fn status(&self) -> StatusCode

fn body_bytes(&self) -> &[u8]

fn headers_wire(&self) -> Shared