Function callbackArray

repos/effect/packages/effect/src/Channel.ts:510–517

(
  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** (Creating array channels from callbacks)
 *
 * ```ts import.meta.vitest
 * import { Channel, Effect, Queue } from "effect"
 *
 * const channel = Channel.callbackArray<number>(Effect.fn(function*(queue) {
 *   yield* Queue.offer(queue, 1)
 *   yield* Queue.offer(queue, 2)
 *   yield* Queue.end(queue)
 * }))
 * await Effect.runPromise(Channel.runCollect(channel)) // => [[1, 2]]
 * ```