Update Capture

frankmcsherry · Mar 23, 2024 · fea3459 · fea3459
1 parent 6c55677
commit fea3459
Show file tree

Hide file tree

Showing 7 changed files with 3 additions and 2 deletions.
diff --git a/...src/dataflow/operators/capture/capture.rs → ...ataflow/operators/core/capture/capture.rs b/...src/dataflow/operators/capture/capture.rs → ...ataflow/operators/core/capture/capture.rs
diff --git a/...y/src/dataflow/operators/capture/event.rs → .../dataflow/operators/core/capture/event.rs b/...y/src/dataflow/operators/capture/event.rs → .../dataflow/operators/core/capture/event.rs
diff --git a/...src/dataflow/operators/capture/extract.rs → ...ataflow/operators/core/capture/extract.rs b/...src/dataflow/operators/capture/extract.rs → ...ataflow/operators/core/capture/extract.rs
diff --git a/timely/src/dataflow/operators/capture/mod.rs → ...rc/dataflow/operators/core/capture/mod.rs b/timely/src/dataflow/operators/capture/mod.rs → ...rc/dataflow/operators/core/capture/mod.rs
diff --git a/.../src/dataflow/operators/capture/replay.rs → ...dataflow/operators/core/capture/replay.rs b/.../src/dataflow/operators/capture/replay.rs → ...dataflow/operators/core/capture/replay.rs
diff --git a/timely/src/dataflow/operators/core/mod.rs b/timely/src/dataflow/operators/core/mod.rs
@@ -1,6 +1,7 @@
 //! Extension traits for `StreamCore` implementing various operators that
 //! are independent of specific container types.
 
+pub mod capture;
 pub mod concat;
 pub mod enterleave;
 pub mod exchange;
@@ -16,6 +17,7 @@ pub mod reclock;
 pub mod to_stream;
 pub mod unordered_input;
 
+pub use capture::Capture;
 pub use concat::{Concat, Concatenate};
 pub use enterleave::{Enter, Leave};
 pub use exchange::Exchange;

diff --git a/timely/src/dataflow/operators/mod.rs b/timely/src/dataflow/operators/mod.rs
@@ -17,7 +17,6 @@ pub use self::filter::Filter;
 pub use self::delay::Delay;
 pub use self::exchange::Exchange;
 pub use self::broadcast::Broadcast;
-pub use self::capture::Capture;
 pub use self::branch::{Branch, BranchWhen};
 pub use self::result::ResultStream;
 pub use self::to_stream::ToStream;
@@ -46,7 +45,7 @@ pub use self::core::exchange;
 pub mod broadcast;
 pub use self::core::probe::{self, Probe};
 pub mod to_stream;
-pub mod capture;
+pub use self::core::capture::{self, Capture};
 pub mod branch;
 pub use self::core::ok_err::{self, OkErr};
 pub use self::core::rc;