diff options
Diffstat (limited to 'ipfs-api/src/read.rs')
| -rw-r--r-- | ipfs-api/src/read.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/ipfs-api/src/read.rs b/ipfs-api/src/read.rs index 567b823..0a009b5 100644 --- a/ipfs-api/src/read.rs +++ b/ipfs-api/src/read.rs @@ -8,7 +8,7 @@ use bytes::BytesMut; use futures::{Async, Stream}; -use reqwest::unstable::async; +use hyper::Chunk; use response::Error; use serde::Deserialize; use serde_json; @@ -62,7 +62,7 @@ where enum ReadState { /// A chunk is ready to be read from. /// - Ready(async::Chunk, usize), + Ready(Chunk, usize), /// The next chunk isn't ready yet. /// @@ -79,7 +79,7 @@ pub struct StreamReader<S> { impl<S> StreamReader<S> where - S: Stream<Item = async::Chunk, Error = Error>, + S: Stream<Item = Chunk, Error = Error>, { #[inline] pub fn new(stream: S) -> StreamReader<S> { @@ -92,7 +92,7 @@ where impl<S> Read for StreamReader<S> where - S: Stream<Item = async::Chunk, Error = Error>, + S: Stream<Item = Chunk, Error = Error>, { fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { loop { @@ -146,6 +146,6 @@ where impl<S> AsyncRead for StreamReader<S> where - S: Stream<Item = async::Chunk, Error = Error>, + S: Stream<Item = Chunk, Error = Error>, { } |