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,
    {
        if let Some(e) = self.err {
            return e.into();
        }

        RequestSender::Rc(self.req.head, Some(self.extra_headers)).send_stream(
            self.req.addr,
            self.req.response_decompress,
            self.req.timeout,
            &self.req.config,
            stream,
        )
    }
/// Complete request construction and send a streaming body.
Complete request construction and send a streaming body.
Complete request construction and send a streaming body .
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,
    {
        if let Some(e) = self.err {
            return e.into();
        }
        RequestSender::Rc(self.req.head, Some(self.extra_headers)).send_stream(
            self.req.addr,
            self.req.response_decompress,
            self.req.timeout,
            &self.req.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 , { if let Some ( e ) = self . err { return e . into ( ) ; } RequestSender :: Rc ( self . req . head , Some ( self . extra_headers ) ) . send_stream ( self . req . addr , self . req . response_decompress , self . req . timeout , & self . req . config , stream , ) }
Complete request construction and send a streaming body.
Complete request construction and send a streaming body .
self
stream
S
self
stream
S