tlpipe.timestream.barrier.Barrier.next

Barrier.next(input)[source]