(self: Stream.Stream<A, E, R>)
| 2231 | |
| 2232 | /** @internal */ |
| 2233 | export const drain = <A, E, R>(self: Stream.Stream<A, E, R>): Stream.Stream<never, E, R> => |
| 2234 | new StreamImpl(channel.drain(toChannel(self))) |
| 2235 | |
| 2236 | /** @internal */ |
| 2237 | export const drainFork = dual< |
no test coverage detected