Function spyCombinator

packages/vue/test/streamFn.test.ts:158–171

(
      input: Stream.Stream<number, never, never> | Effect.Effect<Stream.Stream<number, never, never>>
    )

    // The first argument may be a Stream or an Effect<Stream> (for generator-form handlers),
    // matching how withDefaultToastStream handles it.
    const spyCombinator = (
      input: Stream.Stream<number, never, never> | Effect.Effect<Stream.Stream<number, never, never>>
    ) => {
      const stream: Stream.Stream<number, never, never> = Stream.isStream(input)
        ? input
        : Stream.unwrap(input as Effect.Effect<Stream.Stream<number, never, never>>)
      return stream.pipe(
        Stream.tap((v) =>
          Effect.sync(() => {
            emittedByCombinator.push(v)
          })
        )
      )
    }

    const cmd = Command.streamFn("test-stream-gen-combinator")(
      function*(arg: number) {