mirror of
https://github.com/anomalyco/opencode.git
synced 2026-04-25 15:24:58 +00:00
050336f160
- Replace manual subscription Map with PubSub.unbounded per instance - Per-type PubSubs + wildcard PubSub, cleaned up via addFinalizer - InstanceDisposed published before PubSub shutdown so subscribers see it - Replace makeRunPromise with makeRuntime (single runtime with runPromise + runFork) - Update all 19 services to use makeRuntime destructuring - Legacy facade preserved: publish/subscribe/subscribeAll same signatures - subscribe/subscribeAll fork stream consumer fibers, return interrupt function - Extract Format.file() for explicit formatting, remove event-driven subscription - Inline Format.file() calls in write/edit/apply_patch tools - Drop Bus.once (zero callers)
47 lines
1.4 KiB
TypeScript
47 lines
1.4 KiB
TypeScript
import { expect, test } from "bun:test"
|
|
import { Effect, Layer, ServiceMap } from "effect"
|
|
import { makeRuntime } from "../../src/effect/run-service"
|
|
|
|
class Shared extends ServiceMap.Service<Shared, { readonly id: number }>()("@test/Shared") {}
|
|
|
|
test("makeRuntime shares dependent layers through the shared memo map", async () => {
|
|
let n = 0
|
|
|
|
const shared = Layer.effect(
|
|
Shared,
|
|
Effect.sync(() => {
|
|
n += 1
|
|
return Shared.of({ id: n })
|
|
}),
|
|
)
|
|
|
|
class One extends ServiceMap.Service<One, { readonly get: () => Effect.Effect<number> }>()("@test/One") {}
|
|
const one = Layer.effect(
|
|
One,
|
|
Effect.gen(function* () {
|
|
const svc = yield* Shared
|
|
return One.of({
|
|
get: Effect.fn("One.get")(() => Effect.succeed(svc.id)),
|
|
})
|
|
}),
|
|
).pipe(Layer.provide(shared))
|
|
|
|
class Two extends ServiceMap.Service<Two, { readonly get: () => Effect.Effect<number> }>()("@test/Two") {}
|
|
const two = Layer.effect(
|
|
Two,
|
|
Effect.gen(function* () {
|
|
const svc = yield* Shared
|
|
return Two.of({
|
|
get: Effect.fn("Two.get")(() => Effect.succeed(svc.id)),
|
|
})
|
|
}),
|
|
).pipe(Layer.provide(shared))
|
|
|
|
const { runPromise: runOne } = makeRuntime(One, one)
|
|
const { runPromise: runTwo } = makeRuntime(Two, two)
|
|
|
|
expect(await runOne((svc) => svc.get())).toBe(1)
|
|
expect(await runTwo((svc) => svc.get())).toBe(1)
|
|
expect(n).toBe(1)
|
|
})
|