@@ -18,7 +18,7 @@ use timely::dataflow::operators::{ToStream, Inspect, Map};
1818fn main () {
1919 timely :: execute_from_args (std :: env :: args (), | worker | {
2020 worker . dataflow :: <(),_ ,_ >(| scope | {
21- (0 .. 9 )
21+ (0 .. 10 )
2222 . to_stream (scope )
2323 . map (| x | x + 1 )
2424 . inspect (| x | println! (" hello: {}" , x ));
@@ -37,7 +37,7 @@ use timely::dataflow::operators::{ToStream, Inspect, Map};
3737fn main () {
3838 timely :: execute_from_args (std :: env :: args (), | worker | {
3939 worker . dataflow :: <(),_ ,_ >(| scope | {
40- (0 .. 9 )
40+ (0 .. 10 )
4141 . to_stream (scope )
4242 . map (| x | x . to_string ())
4343 . map (| mut x | { x . truncate (5 ); x } )
@@ -61,7 +61,7 @@ use timely::dataflow::operators::{ToStream, Inspect, Map};
6161fn main () {
6262 timely :: execute_from_args (std :: env :: args (), | worker | {
6363 worker . dataflow :: <(),_ ,_ >(| scope | {
64- (0 .. 9 )
64+ (0 .. 10 )
6565 . to_stream (scope )
6666 . map (| x | x . to_string ())
6767 . map_in_place (| x | x . truncate (5 ))
@@ -81,7 +81,7 @@ use timely::dataflow::operators::{ToStream, Inspect, Map};
8181fn main () {
8282 timely :: execute_from_args (std :: env :: args (), | worker | {
8383 worker . dataflow :: <(),_ ,_ >(| scope | {
84- (0 .. 9 )
84+ (0 .. 10 )
8585 . to_stream (scope )
8686 . flat_map (| x | 0 .. x )
8787 . inspect (| x | println! (" hello: {}" , x ));
@@ -102,7 +102,7 @@ use timely::dataflow::operators::{ToStream, Inspect, Filter};
102102fn main () {
103103 timely :: execute_from_args (std :: env :: args (), | worker | {
104104 worker . dataflow :: <(),_ ,_ >(| scope | {
105- (0 .. 9 )
105+ (0 .. 10 )
106106 . to_stream (scope )
107107 . filter (| x | * x % 2 == 0 )
108108 . inspect (| x | println! (" hello: {}" , x ));
0 commit comments