Function contextWithSink

packages/effect/src/internal/sink.ts:696–699

(
  f: (context: Context.Context<R0>) => Sink.Sink<A, In, L, E, R>
)

/** @internal */
export const contextWithSink = <R0, A, In, L, E, R>(
  f: (context: Context.Context<R0>) => Sink.Sink<A, In, L, E, R>
): Sink.Sink<A, In, L, E, R0 | R> =>
  new SinkImpl(channel.unwrap(Effect.contextWith((context) => toChannel(f(context)))))

/** @internal */
export const every = <In>(predicate: Predicate<In>): Sink.Sink<boolean, In, In> =>