Skip to content

Commit a8b41d9

Browse files
committed
Relax InspectCore trait bounds
Signed-off-by: Moritz Hoffmann <[email protected]>
1 parent 711258b commit a8b41d9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

timely/src/dataflow/operators/core/inspect.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ impl<G: Scope, C: Container + IterContainer> Inspect<G, C> for StreamCore<G, C>
9898
}
9999

100100
/// Inspect containers
101-
pub trait InspectCore<G: Scope, C: IterContainer> {
101+
pub trait InspectCore<G: Scope, C> {
102102
/// Runs a supplied closure on each observed container, and each frontier advancement.
103103
///
104104
/// Rust's `Result` type is used to distinguish the events, with `Ok` for time and data,
@@ -121,7 +121,7 @@ pub trait InspectCore<G: Scope, C: IterContainer> {
121121
fn inspect_container<F>(&self, func: F) -> StreamCore<G, C> where F: FnMut(Result<(&G::Timestamp, &C), &[G::Timestamp]>)+'static;
122122
}
123123

124-
impl<G: Scope, C: Container + IterContainer> InspectCore<G, C> for StreamCore<G, C> {
124+
impl<G: Scope, C: Container> InspectCore<G, C> for StreamCore<G, C> {
125125

126126
fn inspect_container<F>(&self, mut func: F) -> StreamCore<G, C>
127127
where F: FnMut(Result<(&G::Timestamp, &C), &[G::Timestamp]>)+'static

0 commit comments

Comments
 (0)