We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d0caa18 commit e12dd30Copy full SHA for e12dd30
async-stream/tests/stream.rs
@@ -8,11 +8,25 @@ use tokio_test::assert_ok;
8
9
#[tokio::test]
10
async fn noop_stream() {
11
- fn unit() -> impl Stream<Item = ()> {
+ fn any<T>() -> impl Stream<Item = T> {
12
stream! {}
13
}
14
15
- let s = unit();
+ let s = any::<()>();
16
+ pin_mut!(s);
17
+
18
+ while let Some(_) = s.next().await {
19
+ unreachable!();
20
+ }
21
22
+ let s = any::<usize>();
23
24
25
26
27
28
29
+ let s = any::<String>();
30
pin_mut!(s);
31
32
while let Some(_) = s.next().await {
0 commit comments