Benign cargo Download

dispatch.rs

Contains an unbounded block loop

SHA-256bed1c86494517677d2f7048ca2a57b44dc636ddcdd9a25db5917155f89e59de3

MaleculeH(Db)

Evidence

imports futures::Async lines 1–12

1use futures::{Async, AsyncSink, Future, Poll, Sink, Stream};
2use futures::sync::{mpsc, oneshot};
3use tokio_io::{AsyncRead, AsyncWrite};
4use tokio_service::Service;
5
6use super::{Body, Conn, KeepAlive, Http1Transaction, MessageHead, RequestHead, ResponseHead};
7use ::StatusCode;
8
9pub struct Dispatcher<D, Bs, I, B, T, K> {
10    conn: Conn<I, B, T, K>,
11    dispatch: D,
12    b …

Contains an unbounded block loop lines 52–59

5…     }
  }
54
  fn poll_read(&mut self) -> Poll<(), ::Error> {
      loop {
          if self.conn.can_read_head() {
              match self.conn.read_head() {
                  Ok(Async::Ready(So …

English function-word token "with" lines 67–70

35… tch.recv_msg(Ok((head, body))).expect("recv_msg with Ok shouldn't error");
                  },
                  Ok(Async::Ready(None)) => {
 …

English function-word token "the" lines 76–78

48… Err(err))?;
                      // if here, the dispatcher gave the user the error
                      // somewhere else. we still need to  …

English function-word token "for" lines 187–194

187:26… e_done
188    }
189}
190
191
192impl<D, Bs, I, B, T, K> Future for Dispatcher<D, Bs, I, B, T, K>
193where
194    D: Dispatch<PollItem=MessageHead<T::Outgoing>, PollBody …