Function asyncQueue

repos/effect/packages/effect/src/Channel.ts:447–461

(
  scope: Scope.Scope,
  f: (queue: Queue.Queue<A, E | Cause.Done>) => Effect.Effect<unknown, E, R | Scope.Scope>,
  options?: {
    readonly bufferSize?: number | undefined
    readonly strategy?: "sliding" | "dropping" | "suspend" | undefined
  }
)

 *
 * **Example** (Reading the default chunk size)
 *
 * ```ts import.meta.vitest
 * import { Channel } from "effect"
 *
 * Channel.DefaultChunkSize // => 4096
 * ```
 *
 * @category constants
 * @since 4.0.0
 */
export const DefaultChunkSize: number = 4096

const asyncQueue = <A, E = never, R = never>(
  scope: Scope.Scope,
  f: (queue: Queue.Queue<A, E | Cause.Done>) => Effect.Effect<unknown, E, R | Scope.Scope>,
  options?: {
    readonly bufferSize?: number | undefined
    readonly strategy?: "sliding" | "dropping" | "suspend" | undefined