(
channel: Channel.Channel<
never,
E,
End<A, L>,
NonEmptyReadonlyArray<In>,
never,
void,
R
>
)
| 222 | * const channel = Channel.identity<readonly [number, ...Array<number>], never, void>().pipe( |
| 223 | * Channel.drain, |
| 224 | * Channel.mapDone(() => ["consumed"] as const) |
| 225 | * ) |
| 226 | * const sink = Sink.fromChannel(channel) |
| 227 | * |
| 228 | * await Effect.runPromise(Stream.run(Stream.make(1, 2, 3), sink)) // => "consumed" |
| 229 | * ``` |
| 230 | * |
| 231 | * @see {@link toChannel} for converting a `Sink` back to a `Channel` |
| 232 | * @category constructors |
| 233 | * @since 2.0.0 |
| 234 | */ |
| 235 | export const fromChannel = <L, In, E, A, R>( |
| 236 | channel: Channel.Channel< |
| 237 | never, |
| 238 | E, |
| 239 | End<A, L>, |
| 240 | NonEmptyReadonlyArray<In>, |
| 241 | never, |
| 242 | void, |
| 243 | R |
no test coverage detected
searching dependent graphs…