Function pubsubFromOptions

packages/effect/src/internal/stream.ts:7008–7031

(
  options: number | {
    readonly capacity: "unbounded"
    readonly replay?: number | undefined
  } | {
    readonly capacity: number
    readonly strategy?: "sliding" | "dropping" | "suspend" | undefined
    readonly replay?: number | undefined
  }
)

)

const pubsubFromOptions = <A, E>(
  options: number | {
    readonly capacity: "unbounded"
    readonly replay?: number | undefined
  } | {
    readonly capacity: number
    readonly strategy?: "sliding" | "dropping" | "suspend" | undefined
    readonly replay?: number | undefined
  }
): Effect.Effect<PubSub.PubSub<Take.Take<A, E>>> => {
  if (typeof options === "number") {
    return PubSub.bounded(options)
  } else if (options.capacity === "unbounded") {
    return PubSub.unbounded({ replay: options.replay })
  }
  switch (options.strategy) {
    case "dropping":
      return PubSub.dropping(options)
    case "sliding":
      return PubSub.sliding(options)
    default:
      return PubSub.bounded(options)
  }
}

/** @internal */
export const toPubSub = dual<