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

muxers/yamux: Use existing Poll import (#2685)

Browse Source
This commit is contained in:
Thomas Eizinger 2022-06-03 16:27:13 +02:00 committed by GitHub
parent 3611d69e09
commit c36a749478
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
muxers/yamux/src/lib.rs
View File

@ -427,10 +427,7 @@ impl<T> fmt::Debug for LocalIncoming<T> {
impl<T> Stream for Incoming<T> { impl<T> Stream for Incoming<T> {
type Item = Result<yamux::Stream, YamuxError>; type Item = Result<yamux::Stream, YamuxError>;
fn poll_next( fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
mut self: Pin<&mut Self>,
cx: &mut Context<'_>,
) -> std::task::Poll<Option<Self::Item>> {
self.stream.as_mut().poll_next_unpin(cx) self.stream.as_mut().poll_next_unpin(cx)
} }
@ -444,10 +441,7 @@ impl<T> Unpin for Incoming<T> {}
impl<T> Stream for LocalIncoming<T> { impl<T> Stream for LocalIncoming<T> {
type Item = Result<yamux::Stream, YamuxError>; type Item = Result<yamux::Stream, YamuxError>;
fn poll_next( fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
mut self: Pin<&mut Self>,
cx: &mut Context<'_>,
) -> std::task::Poll<Option<Self::Item>> {
self.stream.as_mut().poll_next_unpin(cx) self.stream.as_mut().poll_next_unpin(cx)
} }