Streams: timeoutFirst

[ryanleecode]

What is the problem this feature would solve?

a functionality similar to rxjs timeout({ first: number }) is missing.

What is the feature you are proposing to solve the problem?

import { Duration, pipe, Stream } from 'effect'
import type { LazyArg } from 'effect/Function'

export const timeoutFirstFail =
  <E2>(error: LazyArg<E2>, duration: Duration.DurationInput) => <A, E, R>(stream: Stream.Stream<A, E, R>) =>
    pipe(
      stream,
      Stream.broadcast(2, { capacity: 'unbounded' }),
      Stream.flatMap(([first, second]) =>
        Stream.merge(
          first.pipe(
            Stream.timeoutFail(
              error,
              duration,
            ),
            Stream.take(1),
            Stream.flatMap(() => Stream.empty),
          ),
          second,
          { haltStrategy: 'right' },
        )
      ),
    )

What alternatives have you considered?

No response