use futures::sync::mpsc;
use crate::printer::Printer;
-use crate::timeout_stream::TimeoutStream;
struct BytesCoder<'a>(&'a mut bytes::BytesMut);
impl<'a> std::io::Write for BytesCoder<'a> {
start_height: 0,
relay: true,
}));
- future::ok((sender, TimeoutStream::new(read, timeout)))
+ future::ok((sender, read))
})
}
}