@@ -18,12 +18,13 @@ You can create a new scope in any other scope by invoking the `scoped` method:
1818extern crate timely;
1919
2020use timely :: dataflow :: Scope ;
21+ use timely :: progress :: SubgraphBuilder ;
2122
2223fn main () {
2324 timely :: example (| scope | {
2425
2526 // Create a new scope with the same (u64) timestamp.
26- scope . scoped :: <u64 ,_ ,_ >(" SubScope" , | subscope | {
27+ scope . scoped :: <u64 ,_ ,_ , SubgraphBuilder < _ , _ > >(" SubScope" , | subscope | {
2728 // probably want something here
2829 })
2930
@@ -46,14 +47,15 @@ extern crate timely;
4647
4748use timely :: dataflow :: Scope ;
4849use timely :: dataflow :: operators :: * ;
50+ use timely :: progress :: SubgraphBuilder ;
4951
5052fn main () {
5153 timely :: example (| scope | {
5254
5355 let stream = (0 .. 10 ). to_stream (scope );
5456
5557 // Create a new scope with the same (u64) timestamp.
56- let result = scope . scoped :: <u64 ,_ ,_ >(" SubScope" , | subscope | {
58+ let result = scope . scoped :: <u64 ,_ ,_ , SubgraphBuilder < _ , _ > >(" SubScope" , | subscope | {
5759 stream . enter (subscope )
5860 . inspect_batch (| t , xs | println! (" {:?}, {:?}" , t , xs ))
5961 . leave ()
@@ -108,14 +110,15 @@ extern crate timely;
108110
109111use timely :: dataflow :: Scope ;
110112use timely :: dataflow :: operators :: * ;
113+ use timely :: progress :: SubgraphBuilder ;
111114
112115fn main () {
113116 timely :: example (| scope | {
114117
115118 let stream = (0 .. 10 ). to_stream (scope );
116119
117120 // Create a new scope with a (u64, u32) timestamp.
118- let result = scope . iterative :: <u32 ,_ ,_ >(| subscope | {
121+ let result = scope . iterative :: <u32 ,_ ,_ , SubgraphBuilder < _ , _ > >(| subscope | {
119122 stream . enter (subscope )
120123 . inspect_batch (| t , xs | println! (" {:?}, {:?}" , t , xs ))
121124 . leave ()
0 commit comments