fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-06-29 09:41:34 +00:00
Code Issues Projects Releases Wiki Activity

Remove some Unpin requirements (#1403)

Browse Source
This commit is contained in:
Pierre Krieger
2020-01-23 10:44:52 +01:00
committed by GitHub
parent 3405fc8b32
commit d6bf8a5aeb
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
misc/rw-stream-sink/src/lib.rs
View File

@ -48,7 +48,7 @@ impl<S: TryStream> RwStreamSink<S> {
impl<S> AsyncRead for RwStreamSink<S> impl<S> AsyncRead for RwStreamSink<S>
where where
S: TryStream<Error = io::Error> + Unpin, S: TryStream<Error = io::Error>,
<S as TryStream>::Ok: AsRef<[u8]> <S as TryStream>::Ok: AsRef<[u8]>
{ {
fn poll_read(self: Pin<&mut Self>, cx: &mut Context, buf: &mut [u8]) -> Poll<io::Result<usize>> { fn poll_read(self: Pin<&mut Self>, cx: &mut Context, buf: &mut [u8]) -> Poll<io::Result<usize>> {
@ -75,7 +75,7 @@ where
impl<S> AsyncWrite for RwStreamSink<S> impl<S> AsyncWrite for RwStreamSink<S>
where where
S: TryStream + Sink<<S as TryStream>::Ok, Error = io::Error> + Unpin, S: TryStream + Sink<<S as TryStream>::Ok, Error = io::Error>,
<S as TryStream>::Ok: for<'r> From<&'r [u8]> <S as TryStream>::Ok: for<'r> From<&'r [u8]>
{ {
fn poll_write(self: Pin<&mut Self>, cx: &mut Context, buf: &[u8]) -> Poll<io::Result<usize>> { fn poll_write(self: Pin<&mut Self>, cx: &mut Context, buf: &[u8]) -> Poll<io::Result<usize>> {