aboutsummaryrefslogtreecommitdiff
path: root/src/stream/next.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/stream/next.rs')
-rw-r--r--src/stream/next.rs37
1 files changed, 0 insertions, 37 deletions
diff --git a/src/stream/next.rs b/src/stream/next.rs
deleted file mode 100644
index d9b1f92..0000000
--- a/src/stream/next.rs
+++ /dev/null
@@ -1,37 +0,0 @@
-use crate::stream::Stream;
-
-use core::future::Future;
-use core::marker::PhantomPinned;
-use core::pin::Pin;
-use core::task::{Context, Poll};
-use pin_project_lite::pin_project;
-
-pin_project! {
- /// Future for the [`next`](super::StreamExt::next) method.
- #[derive(Debug)]
- #[must_use = "futures do nothing unless you `.await` or poll them"]
- pub struct Next<'a, St: ?Sized> {
- stream: &'a mut St,
- // Make this future `!Unpin` for compatibility with async trait methods.
- #[pin]
- _pin: PhantomPinned,
- }
-}
-
-impl<'a, St: ?Sized> Next<'a, St> {
- pub(super) fn new(stream: &'a mut St) -> Self {
- Next {
- stream,
- _pin: PhantomPinned,
- }
- }
-}
-
-impl<St: ?Sized + Stream + Unpin> Future for Next<'_, St> {
- type Output = Option<St::Item>;
-
- fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
- let me = self.project();
- Pin::new(me.stream).poll_next(cx)
- }
-}