(
self: Channel<OutElem, OutErr, OutDone, InElem, InErr, InDone, Env>,
f: (
pull: Pull.Pull<OutElem, OutErr, OutDone>,
scope: Scope.Scope
) => Effect.Effect<Pull.Pull<OutElem2, OutErr2, OutDone2, Env2>, OutErrX, EnvX>
)
| 320 | * ) |
| 321 | * await Effect.runPromise(Channel.runCollect(transformedChannel)) // => [2, 4, 6] |
| 322 | * ``` |
| 323 | * |
| 324 | * @category constructors |
| 325 | * @since 4.0.0 |
| 326 | */ |
| 327 | export const transformPull = < |
| 328 | OutElem, |
| 329 | OutErr, |
| 330 | OutDone, |
| 331 | InElem, |
| 332 | InErr, |
| 333 | InDone, |
| 334 | Env, |
| 335 | OutElem2, |
| 336 | OutErr2, |
| 337 | OutDone2, |
| 338 | Env2, |
| 339 | OutErrX, |
| 340 | EnvX |
| 341 | >( |
| 342 | self: Channel<OutElem, OutErr, OutDone, InElem, InErr, InDone, Env>, |
| 343 | f: ( |
| 344 | pull: Pull.Pull<OutElem, OutErr, OutDone>, |
| 345 | scope: Scope.Scope |
| 346 | ) => Effect.Effect<Pull.Pull<OutElem2, OutErr2, OutDone2, Env2>, OutErrX, EnvX> |
| 347 | ): Channel< |
| 348 | OutElem2, |
| 349 | Pull.ExcludeDone<OutErr2> | OutErrX, |
| 350 | OutDone2, |
| 351 | InElem, |
| 352 | InErr, |
| 353 | InDone, |
no test coverage detected
searching dependent graphs…