MCPcopy Create free account
hub / github.com/effect-app/libs / fromTransform

Function fromTransform

repos/effect/packages/effect/src/Sink.ts:254–263  ·  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

252
253/**
254 * Creates a sink that writes its input to a Web `WritableStream`.
255 *
256 * **Example** (Collecting values in a Web stream)
257 *
258 * ```ts import.meta.vitest
259 * import { Effect, Sink, Stream } from "effect"
260 *
261 * const written: Array<number> = []
262 * const sink = Sink.fromWritableStream({
263 * evaluate: () => new WritableStream<number>({
264 * write(value) {
265 * written.push(value)
266 * }

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

Used in the wild real call sites across dependent graphs

searching dependent graphs…