Benign cargo Download

pipeline.rs

Contains an unbounded block loop

SHA-2561a98eca3dc2ca2aa29194b99fbe17c0a48f223a6064faea2f3f30817a31c7cdf

MaleculeH(Db)

Evidence

imports body::Body lines 1–23

1use std::marker::PhantomData;
2use std::rc::Rc;
3use std::{io, mem};
4
5use futures::sync::oneshot;
6use futures::{Async, Future, Poll, Stream};
7use log::Level::Debug;
8
9use body::{Body, BodyStream};
10use context::{ActorHttpContext, Frame};
11use error::Error;
12use handler::{AsyncResult, AsyncResultItem};
13use header::ContentEncoding;
14use httprequest::HttpRequest;
15use httpresponse::HttpResponse;
16use middleware::{Finished, Middleware, Response, Started};
17use server::{HttpHandlerTask, Writer, WriterState};
18
19#[doc(hidden)]
⋯4 lines

English function-word token "for" lines 116–118

9… 'static, H: PipelineHandler<S>> HttpHandlerTask for Pipeline<S, H> {
  fn disconnected(&mut self) {
      self.0.disconnected = Some(true);

Contains an unbounded block loop lines 122–127

10… et mut state = mem::replace(&mut self.1, PipelineState::None);
123
      loop {
          if let PipelineState::Response(st) = state {
              match st.poll_io(io, &mut self.0, &self.2) {
      …

English function-word token "and" lines 195–201

25… , H> {
      // execute middlewares, we need this stage because middlewares could be
      // non-async and we can move to next state immediately
      let len = mws.len() as u16;
199
      loop {
…

English function-word token "the" lines 568–569

568:16…              // always poll stream or actor for the first time
569                            match self.resp.as_mut().unwrap().replace_body(Body::Em …