eater/async-std
1
0
Fork 0
forked from mirror/async-std
Code Issues Pull requests Releases Wiki Activity

Make Once a DoubleEndedStream

Browse source
This commit is contained in:
Felipe Sere 2019-11-23 22:27:08 +00:00
parent f9a4c35fd6
commit 41cf0f855b
1 changed files with 7 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/stream/once.rs
View file

@ -4,6 +4,7 @@ use pin_project_lite::pin_project;
use crate::stream::Stream; use crate::stream::Stream;
use crate::task::{Context, Poll}; use crate::task::{Context, Poll};
use crate::stream::double_ended_stream::DoubleEndedStream;
/// Creates a stream that yields a single item. /// Creates a stream that yields a single item.
/// ///
@ -46,3 +47,9 @@ impl<T> Stream for Once<T> {
Poll::Ready(self.project().value.take()) Poll::Ready(self.project().value.take())
} }
} }
impl <T> DoubleEndedStream for Once<T> {
fn poll_next_back(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
Poll::Ready(self.project().value.take())
}
}