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

Function fromQueue

repos/effect/packages/effect/src/Sink.ts:464–476  ·  view source on GitHub ↗
(
  queue: Queue.Queue<A, Cause.Done>
)

Source from the content-addressed store, hash-verified

462 df: (_: D) => F,
463 fg: (_: F) => G,
464 gh: (_: G) => H,
465 hi: (_: H) => I,
466 ij: (_: I) => J,
467 jk: (_: J) => K,
468 kl: (_: K) => Effect.Effect<L, E, R>
469 ): Sink<L, In, never, E, Exclude<R, Scope.Scope>>
470 }
471}
472
473/**
474 * Creates a sink that ignores upstream input and completes from an effect that
475 * already returns an `End`.
476 *
477 * **When to use**
478 *
479 * Use when you need to create a sink from an effect that returns both the sink

Callers

nothing calls this directly

Calls 3

offerAllMethod · 0.80
fromTransformFunction · 0.70
pipeMethod · 0.65

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…