Function enqueue

packages/effect/src/internal/stream.ts:1794–1802

(last: Chunk.Chunk<A>)

        const handoff = yield* Handoff.make<HandoffSignal.HandoffSignal<A, E>>()

        function enqueue(last: Chunk.Chunk<A>): Effect.Effect<
          Channel.Channel<Chunk.Chunk<A>, unknown, E, unknown, unknown, unknown>
        > {
          return Clock.sleep(duration).pipe(
            Effect.as(last),
            Effect.forkIn(scope),
            Effect.map((fiber) => consumer(DebounceState.previous(fiber)))
          )
        }

        const producer: Channel.Channel<never, Chunk.Chunk<A>, E, E, unknown, unknown> = core.readWithCause({
          onInput: (input: Chunk.Chunk<A>) =>