Treatment barrier

std/flow::barrier

Generics

◻ T (any)

Inputs

⇥ leverage: Block<bool>
⇥ stream: Stream<T>

Outputs

↦ passed: Stream<T>

Barrier stream under condition.

Awaits leverage to let stream pass if it is true, else closes the stream.