Timestream.shift_until

Timestream.shift_until(predicate)

Return a Timestream shifting each point forward to the next time predicate is true.

Note that if the predicate evaluates to true at the same time as self,

the point will be emitted at that time.

If multiple values are shifted to the same time, they will be emitted in

the order in which they originally occurred.

Parameters:

predicate (Arg)

The predicate to determine whether to emit shifted rows.