|
|
@ -59,7 +59,7 @@ impl<R: AsyncRead + ?Sized> AsyncRead for ReverseSink<R>
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
alloc_local_bytes(buf.len(), |temp_buf| -> Poll<io::Result<usize>> {
|
|
|
|
alloc_local_bytes(buf.len(), |temp_buf| -> Poll<io::Result<usize>> {
|
|
|
|
//XXX: Does this work? I dunno... Maybe just pin and poll a local `async{}` block.
|
|
|
|
//XXX: Does this work? I dunno... Maybe just pin and poll a local `async{}` block (this doesn't work, because `raw` needs to be `Unpin`... sigh....).
|
|
|
|
|
|
|
|
|
|
|
|
// Read encrypted bytes into `temp_buf`.
|
|
|
|
// Read encrypted bytes into `temp_buf`.
|
|
|
|
let filled_buffer: &[u8] = try_ready!(proj.raw.poll_read(cx, temp_buf).map_ok(|read| {
|
|
|
|
let filled_buffer: &[u8] = try_ready!(proj.raw.poll_read(cx, temp_buf).map_ok(|read| {
|
|
|
|