From c2e8fefce9ddad0aef5afcac0238b4dc6ae0ddcb Mon Sep 17 00:00:00 2001
From: tom <nooberfsh@gmail.com>
Date: Tue, 20 Dec 2022 20:16:28 +0800
Subject: [PATCH] Simplify `trace` construction in the `cursors` example.
 (#374)

---
 examples/cursors.rs | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/examples/cursors.rs b/examples/cursors.rs
index 5ab55b5e6..cd916530c 100644
--- a/examples/cursors.rs
+++ b/examples/cursors.rs
@@ -39,10 +39,10 @@ use std::collections::BTreeMap;
 
 use timely::dataflow::operators::probe::Handle;
 use timely::progress::frontier::AntichainRef;
+use timely::dataflow::operators::Probe;
 
 use differential_dataflow::input::Input;
 use differential_dataflow::operators::arrange::ArrangeByKey;
-use differential_dataflow::operators::*;
 use differential_dataflow::trace::cursor::Cursor;
 use differential_dataflow::trace::TraceReader;
 
@@ -65,8 +65,7 @@ fn main() {
             /* Be sure to attach probe to arrangements we want to enumerate;
              * so we know when all updates for a given epoch have been added to the arrangement. */
             graph_arr
-                .as_collection(|_, v| *v)
-                .consolidate()
+                .stream
                 //.inspect(move |x| println!("{:?}", x))
                 .probe_with(&mut probe);