MCPcopy Create free account
hub / github.com/Effect-TS/effect / fromTransform

Function fromTransform

packages/effect/src/Sink.ts:302–311  ·  view source on GitHub ↗
(
  transform: (
    upstream: Pull.Pull<NonEmptyReadonlyArray<In>, never, void>,
    scope: Scope.Scope
  ) => Effect.Effect<End<A, L>, E, R>
)

Source from the content-addressed store, hash-verified

300 * @since 4.0.0
301 */
302export 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.

Callers 15

fromChannelFunction · 0.70
makeFunction · 0.70
Sink.tsFile · 0.70
fromQueueFunction · 0.70
suspendFunction · 0.70
foldFunction · 0.70
foldArrayFunction · 0.70
transformEffectFunction · 0.70
takeFunction · 0.70
reduceWhileFunction · 0.70
reduceWhileEffectFunction · 0.70
reduceWhileArrayFunction · 0.70

Calls

no outgoing calls

Tested by

no test coverage detected