From fe1e6e9bc9bb34b6e890e396e0a4bd3a3dd2fd05 Mon Sep 17 00:00:00 2001 From: Brennan Vincent Date: Fri, 29 May 2020 14:31:01 -0400 Subject: [PATCH] Update ok_err.rs fix comment --- timely/src/dataflow/operators/ok_err.rs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/timely/src/dataflow/operators/ok_err.rs b/timely/src/dataflow/operators/ok_err.rs index a3722a65c..36d794681 100644 --- a/timely/src/dataflow/operators/ok_err.rs +++ b/timely/src/dataflow/operators/ok_err.rs @@ -8,9 +8,10 @@ use crate::Data; /// Extension trait for `Stream`. pub trait OkErr { /// Takes one input stream and splits it into two output streams. - /// For each record, the supplied closure is called with a reference to - /// the data and its time. If it returns true, the record will be sent - /// to the second returned stream, otherwise it will be sent to the first. + /// For each record, the supplied closure is called with the data. + /// If it returns `Ok(x)`, then `x` will be sent + /// to the first returned stream; otherwise, if it returns `Err(e)`, + /// then `e` will be sent to the second. /// /// If the result of the closure only depends on the time, not the data, /// `branch_when` should be used instead.