Function fromEffect

packages/effect/src/Sink.ts:499–501

(
  effect: Effect.Effect<A, E, R>
)

 * @since 2.0.0
 */
export const fromEffect = <A, E, R>(
  effect: Effect.Effect<A, E, R>
): Sink<A, unknown, never, E, R> => fromEffectEnd(Effect.map(effect, (a) => [a]))

/**
 * Creates a sink that offers every consumed input element to a queue.