Skip to content

Commit 04718c4

Browse files
committed
Use code style in example/stream as in future's
1 parent b21f0f6 commit 04718c4

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

examples/stream.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,13 @@
1-
#![type_length_limit="2111998"]
2-
31
use futures::executor;
42
use futures_async_combinators::stream::*;
53

64
fn main() {
75
let stream = iter(1..=3);
86
let stream = map(stream, |x| x + 1);
97
let stream = map(stream, |x| x * 2);
8+
let stream = inspect(stream, |x| {
9+
dbg!(x);
10+
});
1011

1112
let collect_future = collect(stream);
1213
let collection: Vec<_> = executor::block_on(collect_future);

0 commit comments

Comments
 (0)