comment/doctest clean-up

frankmcsherry · Mar 23, 2024 · 0f42c3e · 0f42c3e
1 parent fea3459
commit 0f42c3e
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 8 deletions.
diff --git a/timely/src/dataflow/operators/core/capture/replay.rs b/timely/src/dataflow/operators/core/capture/replay.rs
@@ -50,7 +50,7 @@ use crate::Container;
 
 /// Replay a capture stream into a scope with the same timestamp.
 pub trait Replay<T: Timestamp, C> : Sized {
-    /// Replays `self` into the provided scope, as a `StreamCore<S,CD>`.
+    /// Replays `self` into the provided scope, as a `StreamCore<S, C>`.
     fn replay_into<S: Scope<Timestamp=T>>(self, scope: &mut S) -> StreamCore<S, C> {
         self.replay_core(scope, Some(std::time::Duration::new(0, 0)))
     }

diff --git a/timely/src/dataflow/operators/core/reclock.rs b/timely/src/dataflow/operators/core/reclock.rs
@@ -19,7 +19,7 @@ pub trait Reclock<S: Scope> {
     /// # Examples
     ///
     /// ```
-    /// use timely::dataflow::operators::{Inspect, ToStream, Delay, Map, Reclock, Capture};
+    /// use timely::dataflow::operators::{ToStream, Delay, Map, Reclock, Capture};
     /// use timely::dataflow::operators::capture::Extract;
     ///
     /// let captured = timely::example(|scope| {
@@ -36,7 +36,6 @@ pub trait Reclock<S: Scope> {
     ///
     ///     // reclock the data.
     ///     data.reclock(&clock)
-    ///         .inspect_batch(|t,x| println!("SEEN: {:?}, {:?}", t, x))
     ///         .capture()
     /// });
     ///

diff --git a/timely/src/dataflow/operators/core/to_stream.rs b/timely/src/dataflow/operators/core/to_stream.rs
@@ -12,13 +12,12 @@ pub trait ToStream<C: Container> {
     /// # Examples
     ///
     /// ```
-    /// use timely::dataflow::operators::ToStream;
-    /// use timely::dataflow::operators::Capture;
-    /// use timely::dataflow::operators::capture::Extract;
+    /// use timely::dataflow::operators::core::{ToStream, Capture};
+    /// use timely::dataflow::operators::core::capture::Extract;
     ///
     /// let (data1, data2) = timely::example(|scope| {
-    ///     let data1 = (0..3).to_stream(scope).capture();
-    ///     let data2 = vec![0,1,2].to_stream(scope).capture();
+    ///     let data1 = (0..3).to_stream(scope).container::<Vec<_>>().capture();
+    ///     let data2 = vec![0,1,2].to_stream(scope).container::<Vec<_>>().capture();
     ///     (data1, data2)
     /// });
     ///