Stream.takeWhile(fn: (value: T) => Promisable<boolean>): Stream<T, E>
Yields successful values while the predicate returns true. Once the predicate returns false, iteration stops. Errors pass through until the stream is stopped. If the predicate throws, an error result is emitted and iteration stops.
Stream<T, E>