(
transform: (
upstream: Pull.Pull<NonEmptyReadonlyArray<In>, never, void>,
scope: Scope.Scope
) => Effect.Effect<End<A, L>, E, R>
)
| 300 | * @since 4.0.0 |
| 301 | */ |
| 302 | export const fromTransform = <In, A, E, R, L = never>( |
| 303 | transform: ( |
| 304 | upstream: Pull.Pull<NonEmptyReadonlyArray<In>, never, void>, |
| 305 | scope: Scope.Scope |
| 306 | ) => Effect.Effect<End<A, L>, E, R> |
| 307 | ): Sink<A, In, L, E, R> => { |
| 308 | const self = Object.create(SinkProto) |
| 309 | self.transform = transform |
| 310 | return self |
| 311 | } |
| 312 | |
| 313 | /** |
| 314 | * Creates a `Channel` from a Sink. |
no outgoing calls
no test coverage detected