pub fn send_stream<S, E>(self, stream: S) -> SendClientRequest
    where
        S: Stream<Item = Result<Bytes, E>> + Unpin + 'static,
        E: Into<Box<dyn StdError>> + 'static,
    {
        let slf = match self.prep_for_sending() {
            Ok(slf) => slf,
            Err(e) => return e.into(),
        };

        RequestSender::Owned(slf.head).send_stream(
            slf.addr,
            slf.response_decompress,
            slf.timeout,
            &slf.config,
            stream,
        )
    }
/// Set an streaming body and generate `ClientRequest`.
Set an streaming body and generate `ClientRequest`.
Set an streaming body and generate ` ClientRequest ` .
pub fn send_stream<S, E>(self, stream: S) -> SendClientRequest
    where
        S: Stream<Item = Result<Bytes, E>> + Unpin + 'static,
        E: Into<Box<dyn StdError>> + 'static,
    {
        let slf = match self.prep_for_sending() {
            Ok(slf) => slf,
            Err(e) => return e.into(),
        };
        RequestSender::Owned(slf.head).send_stream(
            slf.addr,
            slf.response_decompress,
            slf.timeout,
            &slf.config,
            stream,
        )
    }
pub fn send_stream < S , E > ( self , stream : S ) -> SendClientRequest where S : Stream < Item = Result < Bytes , E > > + Unpin + ' static , E : Into < Box < dyn StdError > > + ' static , { let slf = match self . prep_for_sending ( ) { Ok ( slf ) => slf , Err ( e ) => return e . into ( ) , } ; RequestSender :: Owned ( slf . head ) . send_stream ( slf . addr , slf . response_decompress , slf . timeout , & slf . config , stream , ) }
Set an streaming body and generate `ClientRequest`.
Set an streaming body and generate ` ClientRequest ` .
self
stream
S
self
stream
S