pipeline.rs
Contains an unbounded block loopimports actix::Request
SHA-2562189995608e78cecee44b847be1da8ae92cad7a78e715f1df38bbee28c5ead47
MaleculeH(Db)Md(In₄)
Evidence
1use bytes::{Bytes, BytesMut};
2use futures::sync::oneshot;
3use futures::{Async, Future, Poll, Stream};
4use http::header::CONTENT_ENCODING;
5use std::time::{Duration, Instant};
6use std::{io, mem};
7use tokio_timer::Delay;
8
9use actix::{Addr, Request, SystemService};
10
11use super::{
12 ClientConnector, ClientConnectorError, ClientRequest, ClientResponse, Connect,
13 Connection, HttpClientWriter, HttpResponseParser, HttpResponseParserError,
14};
15use body::{Body, BodyStream};
16use context::{ActorHttpContext, Frame};
17use error::Error;
18use error::PayloadError;
19use header::ContentEncoding;
20use http::{Method, Uri};
21use httpmessage::HttpMessage;
22use server::input::PayloadStream;
23use server::WriterState;
24
25/// A set of errors that can occur during request sending and response reading
26#[derive(Fail, Debug)]
27pub enum SendRequestError {
28 /// Response took too long
29 #[fail(display = "Timeout while waiting for response")]
30 Timeout,
31 /// Failed to connect to host
32 #[fail(display = "Failed to c …
113:18… st timeout
114 ///
115 /// Request timeout is the total time before a response must be received.
116 /// Default value is 5 seconds.
117 pub fn …
144:34… ;
145
146 fn poll(&mut self) -> Poll<Self::Item, Self::Error> {
147 loop {
148 let state = mem::replace(&mut self.state, State::None);
149
150 match state {
151 State::New => …