Lines Matching refs:Async

6 use futures::{Async, Poll};
101 Ok(Async::Ready(Bytes::new())) in decode()
113 Ok(Async::Ready(buf)) in decode()
123 return Ok(Async::Ready(Bytes::new())); in decode()
126 return Ok(Async::Ready(buf)); in decode()
132 Ok(Async::Ready(Bytes::new())) in decode()
139 Ok(Async::Ready(slice)) in decode()
182 End => Ok(Async::Ready(ChunkedState::End)), in step()
201 b'\t' | b' ' => return Ok(Async::Ready(ChunkedState::SizeLws)), in read_size()
202 b';' => return Ok(Async::Ready(ChunkedState::Extension)), in read_size()
203 b'\r' => return Ok(Async::Ready(ChunkedState::SizeLf)), in read_size()
209 Ok(Async::Ready(ChunkedState::Size)) in read_size()
215 b'\t' | b' ' => Ok(Async::Ready(ChunkedState::SizeLws)), in read_size_lws()
216 b';' => Ok(Async::Ready(ChunkedState::Extension)), in read_size_lws()
217 b'\r' => Ok(Async::Ready(ChunkedState::SizeLf)), in read_size_lws()
227 b'\r' => Ok(Async::Ready(ChunkedState::SizeLf)), in read_extension()
228 _ => Ok(Async::Ready(ChunkedState::Extension)), // no supported extensions in read_extension()
236 Ok(Async::Ready(ChunkedState::EndCr)) in read_size_lf()
239 Ok(Async::Ready(ChunkedState::Body)) in read_size_lf()
270 Ok(Async::Ready(ChunkedState::Body)) in read_body()
272 Ok(Async::Ready(ChunkedState::BodyCr)) in read_body()
277 b'\r' => Ok(Async::Ready(ChunkedState::BodyLf)), in read_body_cr()
283 b'\n' => Ok(Async::Ready(ChunkedState::Size)), in read_body_lf()
290 b'\r' => Ok(Async::Ready(ChunkedState::EndLf)), in read_end_cr()
296 b'\n' => Ok(Async::Ready(ChunkedState::End)), in read_end_lf()
324 use futures::{Async, Poll};
335 Ok(Async::Ready(buf.split_to(n).freeze())) in read_mem()
337 Ok(Async::Ready(Bytes::new())) in read_mem()
345 impl HelpUnwrap<Bytes> for Async<Bytes> { implementation
348 Async::Ready(bytes) => bytes, in unwrap()
349 Async::NotReady => panic!(), in unwrap()
353 impl HelpUnwrap<ChunkedState> for Async<ChunkedState> { implementation
356 Async::Ready(state) => state, in unwrap()
357 Async::NotReady => panic!(), in unwrap()
493 Async::Ready(buf) => { in read_async()
499 Async::NotReady => { in read_async()