bjoernager/rust
bjoernager/rust
1
Fork 0
Code Activity

Move {core,std}::stream::Stream to {core,std}::async_iter::AsyncIterator.

Browse source
This commit is contained in:
Charles Lew 2022-02-03 17:56:10 +08:00
parent 796bf14f2e
commit 18130a21dc
8 changed files with 83 additions and 84 deletions
Download patch file Download diff file Expand all files Collapse all files

6
library/core/src/panic/unwind_safe.rs
View file

@ -1,10 +1,10 @@
use crate::async_iter::AsyncIterator;
use crate::cell::UnsafeCell;
use crate::fmt;
use crate::future::Future;
use crate::ops::{Deref, DerefMut};
use crate::pin::Pin;
use crate::ptr::{NonNull, Unique};
use crate::stream::Stream;
use crate::task::{Context, Poll};
/// A marker trait which represents "panic safe" types in Rust.
@ -290,8 +290,8 @@ impl<F: Future> Future for AssertUnwindSafe<F> {
}
}
#[unstable(feature = "async_stream", issue = "79024")]
impl<S: Stream> Stream for AssertUnwindSafe<S> {
#[unstable(feature = "async_iterator", issue = "79024")]
impl<S: AsyncIterator> AsyncIterator for AssertUnwindSafe<S> {
type Item = S::Item;
fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<S::Item>> {