Function offer

packages/sql/src/SqlStream.ts:46–51

(chunk: Chunk.Chunk<A>)

        }

        const offer = (chunk: Chunk.Chunk<A>) =>
          Queue.isFull(queue).pipe(
            Effect.tap((full) => (full ? effects.onPause : Effect.void)),
            Effect.zipRight(Queue.offer(queue, chunk)),
            Effect.zipRight(effects.onResume)
          )

        effects = register({
          single: (item) => runFork(offer(Chunk.of(item))),