Deploying to gh-pages from @ 7ffb5e2 🚀

Author: frankmcsherry

chapter_2/chapter_2_1.html

@@ -192,7 +192,7 @@ <h1 id="creating-inputs"><a class="header" href="#creating-inputs">Creating Inpu
         worker.dataflow(|scope| {
 
             let stream1 = input.to_stream(scope);
-            let stream2 = (0 .. 9).to_stream(scope);
+            let stream2 = (0 .. 10).to_stream(scope);
 
         });
 

chapter_2/chapter_2_2.html

@@ -183,7 +183,7 @@ <h1 id="observing-outputs"><a class="header" href="#observing-outputs">Observing
 fn main() {
     timely::execute_from_args(std::env::args(), |worker| {
         worker.dataflow::&lt;(),_,_&gt;(|scope| {
-            (0 .. 9)
+            (0 .. 10)
                 .to_stream(scope)
                 .inspect(|x| println!("hello: {}", x));
         });

chapter_2/chapter_2_3.html

@@ -186,7 +186,7 @@ <h2 id="mapping"><a class="header" href="#mapping">Mapping</a></h2>
 fn main() {
     timely::execute_from_args(std::env::args(), |worker| {
         worker.dataflow::&lt;(),_,_&gt;(|scope| {
-            (0 .. 9)
+            (0 .. 10)
                 .to_stream(scope)
                 .map(|x| x + 1)
                 .inspect(|x| println!("hello: {}", x));
@@ -201,7 +201,7 @@ <h2 id="mapping"><a class="header" href="#mapping">Mapping</a></h2>
 fn main() {
     timely::execute_from_args(std::env::args(), |worker| {
         worker.dataflow::&lt;(),_,_&gt;(|scope| {
-            (0 .. 9)
+            (0 .. 10)
                 .to_stream(scope)
                 .map(|x| x.to_string())
                 .map(|mut x| { x.truncate(5); x } )
@@ -219,7 +219,7 @@ <h3 id="map-variants"><a class="header" href="#map-variants">Map variants</a></h
 fn main() {
     timely::execute_from_args(std::env::args(), |worker| {
         worker.dataflow::&lt;(),_,_&gt;(|scope| {
-            (0 .. 9)
+            (0 .. 10)
                 .to_stream(scope)
                 .map(|x| x.to_string())
                 .map_in_place(|x| x.truncate(5))
@@ -235,7 +235,7 @@ <h3 id="map-variants"><a class="header" href="#map-variants">Map variants</a></h
 fn main() {
     timely::execute_from_args(std::env::args(), |worker| {
         worker.dataflow::&lt;(),_,_&gt;(|scope| {
-            (0 .. 9)
+            (0 .. 10)
                 .to_stream(scope)
                 .flat_map(|x| 0 .. x)
                 .inspect(|x| println!("hello: {}", x));
@@ -251,7 +251,7 @@ <h2 id="filtering"><a class="header" href="#filtering">Filtering</a></h2>
 fn main() {
     timely::execute_from_args(std::env::args(), |worker| {
         worker.dataflow::&lt;(),_,_&gt;(|scope| {
-            (0 .. 9)
+            (0 .. 10)
                 .to_stream(scope)
                 .filter(|x| *x % 2 == 0)
                 .inspect(|x| println!("hello: {}", x));

print.html

@@ -614,7 +614,7 @@ <h2 id="responding-to-progress-information"><a class="header" href="#responding-
         worker.dataflow(|scope| {
 
             let stream1 = input.to_stream(scope);
-            let stream2 = (0 .. 9).to_stream(scope);
+            let stream2 = (0 .. 10).to_stream(scope);
 
         });
 
@@ -633,7 +633,7 @@ <h2 id="other-sources"><a class="header" href="#other-sources">Other sources</a>
 fn main() {
     timely::execute_from_args(std::env::args(), |worker| {
         worker.dataflow::&lt;(),_,_&gt;(|scope| {
-            (0 .. 9)
+            (0 .. 10)
                 .to_stream(scope)
                 .inspect(|x| println!("hello: {}", x));
         });
@@ -687,7 +687,7 @@ <h2 id="mapping"><a class="header" href="#mapping">Mapping</a></h2>
 fn main() {
     timely::execute_from_args(std::env::args(), |worker| {
         worker.dataflow::&lt;(),_,_&gt;(|scope| {
-            (0 .. 9)
+            (0 .. 10)
                 .to_stream(scope)
                 .map(|x| x + 1)
                 .inspect(|x| println!("hello: {}", x));
@@ -702,7 +702,7 @@ <h2 id="mapping"><a class="header" href="#mapping">Mapping</a></h2>
 fn main() {
     timely::execute_from_args(std::env::args(), |worker| {
         worker.dataflow::&lt;(),_,_&gt;(|scope| {
-            (0 .. 9)
+            (0 .. 10)
                 .to_stream(scope)
                 .map(|x| x.to_string())
                 .map(|mut x| { x.truncate(5); x } )
@@ -720,7 +720,7 @@ <h3 id="map-variants"><a class="header" href="#map-variants">Map variants</a></h
 fn main() {
     timely::execute_from_args(std::env::args(), |worker| {
         worker.dataflow::&lt;(),_,_&gt;(|scope| {
-            (0 .. 9)
+            (0 .. 10)
                 .to_stream(scope)
                 .map(|x| x.to_string())
                 .map_in_place(|x| x.truncate(5))
@@ -736,7 +736,7 @@ <h3 id="map-variants"><a class="header" href="#map-variants">Map variants</a></h
 fn main() {
     timely::execute_from_args(std::env::args(), |worker| {
         worker.dataflow::&lt;(),_,_&gt;(|scope| {
-            (0 .. 9)
+            (0 .. 10)
                 .to_stream(scope)
                 .flat_map(|x| 0 .. x)
                 .inspect(|x| println!("hello: {}", x));
@@ -752,7 +752,7 @@ <h2 id="filtering"><a class="header" href="#filtering">Filtering</a></h2>
 fn main() {
     timely::execute_from_args(std::env::args(), |worker| {
         worker.dataflow::&lt;(),_,_&gt;(|scope| {
-            (0 .. 9)
+            (0 .. 10)
                 .to_stream(scope)
                 .filter(|x| *x % 2 == 0)
                 .inspect(|x| println!("hello: {}", x));