@@ -61,9 +61,9 @@ pub trait Operator<G: Scope, C1> {
6161 & mut OutputBuilderSession < ' _ , G :: Timestamp , CB > ) +' static ,
6262 P : ParallelizationContract < G :: Timestamp , C1 > ;
6363
64- /// Creates a new dataflow operator that partitions its input stream by a parallelization
65- /// strategy `pact`, and repeatedly invokes `logic`, the function returned by the function passed as `constructor`.
66- /// `logic` can read from the input stream, write to the output stream, and inspect the frontier at the input.
64+ /// Creates a new dataflow operator that partitions its input stream by a parallelization strategy `pact`,
65+ /// and repeatedly invokes the closure supplied as `logic`, which can read from the input stream, write to
66+ /// the output stream, and inspect the frontier at the input.
6767 ///
6868 /// # Examples
6969 /// ```
@@ -186,9 +186,9 @@ pub trait Operator<G: Scope, C1> {
186186 P1 : ParallelizationContract < G :: Timestamp , C1 > ,
187187 P2 : ParallelizationContract < G :: Timestamp , C2 > ;
188188
189- /// Creates a new dataflow operator that partitions its input streams by a parallelization
190- /// strategy `pact`, and repeatedly invokes `logic`, the function returned by the function passed as `constructor`.
191- /// `logic` can read from the input streams, write to the output stream, and inspect the frontier at the inputs.
189+ /// Creates a new dataflow operator that partitions its input stream by a parallelization strategy `pact`,
190+ /// and repeatedly invokes the closure supplied as `logic`, which can read from the input streams, write to
191+ /// the output stream, and inspect the frontier at the inputs.
192192 ///
193193 /// # Examples
194194 /// ```
0 commit comments