TakeFor<T> extension

on

• Stream<T>

Methods

takeFor(Duration duration) → Stream<T>

Available on Stream<T>, provided by the TakeFor extension

Takes events from the stream for the specified duration. The returned stream will emit events from the original stream until the specified duration has elapsed since the subscription started.