Function findSink

packages/effect/test/Sink/racing.test.ts:13–24

(a: A)

import { unfoldEffect } from "../utils/unfoldEffect.js"

const findSink = <A>(a: A): Sink.Sink<A, A, A, void> =>
  pipe(
    Sink.fold<Option.Option<A>, A>(
      Option.none(),
      Option.isNone,
      (_, v) => (a === v ? Option.some(a) : Option.none())
    ),
    Sink.mapEffect(Option.match({
      onNone: () => Effect.failSync(constVoid),
      onSome: Effect.succeed
    }))
  )

const sinkRaceLaw = <E, A, L>(
  stream: Stream.Stream<A>,