Function runHead

packages/effect/src/internal/stream.ts:5867–5869

(
  self: Stream.Stream<A, E, R>
)

/** @internal */
export const runHead = <A, E, R>(
  self: Stream.Stream<A, E, R>
): Effect.Effect<Option.Option<A>, E, R> => run(self, sink_.head<A>())

/** @internal */
export const runIntoPubSub = dual<