Files
scriptc/tests/fixtures/effect/queue-backpressure.ts
Chris Tate 2069684b40 Expand static Effect support across common APIs (#598)
* Expand static Effect support across common APIs

* Preserve compiler parity across expanded Effect patterns

* Fix compiler regressions exposed by Effect coverage

* Bound shared type conversion traversal

* Clarify conversion contracts and tidy fixtures

* Run every Effect fixture in CI shards

* Preserve inferred array assignments in concurrent Effect programs

* Record inferred array fixture compiler ordering
2026-10-01 02:49:31 -05:00

4 lines
358 B
TypeScript

import { Effect, Queue, Fiber } from "effect";
const p = Effect.gen(function* () { const q = yield* Queue.bounded<number>(1); yield* Queue.offer(q, 1); const f = yield* Effect.fork(Queue.offer(q, 2)); const a = yield* Queue.take(q); yield* Fiber.join(f); const b = yield* Queue.take(q); yield* Queue.shutdown(q); console.log(a, b); });
Effect.runPromise(p);