(predicate: Predicate<In>)
| 569 | |
| 570 | /** @internal */ |
| 571 | export const dropUntil = <In>(predicate: Predicate<In>): Sink.Sink<unknown, In, In> => |
| 572 | new SinkImpl( |
| 573 | pipe(toChannel(dropWhile((input: In) => !predicate(input))), channel.pipeToOrFail(toChannel(drop<In>(1)))) |
| 574 | ) |
| 575 | |
| 576 | /** @internal */ |
| 577 | export const dropUntilEffect = <In, E, R>( |