lmin/zmo-cli
1
0
Fork 0
Code Issues Pull Requests Actions 6 Packages Projects Releases Wiki Activity

test(project): use Deferred for dispose handoff (#27225)

Browse Source
This commit is contained in:
Kit Langton
2026-05-12 22:32:50 -04:00
committed by GitHub
parent 91a9514ed0
commit ff16eb8dea
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/opencode/test/project/instance.test.ts
View File

@@ -1,6 +1,6 @@
import { describe, expect } from "bun:test" import { describe, expect } from "bun:test"
import { CrossSpawnSpawner } from "@opencode-ai/core/cross-spawn-spawner" import { CrossSpawnSpawner } from "@opencode-ai/core/cross-spawn-spawner"
import { Deferred, Effect, Fiber, Layer, Queue } from "effect" import { Deferred, Effect, Fiber, Layer } from "effect"
import { InstanceRef } from "../../src/effect/instance-ref" import { InstanceRef } from "../../src/effect/instance-ref"
import { registerDisposer } from "../../src/effect/instance-registry" import { registerDisposer } from "../../src/effect/instance-registry"
import { InstanceBootstrap } from "../../src/project/bootstrap-service" import { InstanceBootstrap } from "../../src/project/bootstrap-service"
@@ -203,20 +203,20 @@ describe("InstanceStore", () => {
const dir = yield* tmpdirScoped({ git: true }) const dir = yield* tmpdirScoped({ git: true })
const store = yield* InstanceStore.Service const store = yield* InstanceStore.Service
const disposing = yield* Deferred.make<void>() const disposing = yield* Deferred.make<void>()
const releaseDispose = yield* Queue.unbounded<() => void>() const releaseDispose = yield* Deferred.make<() => void>()
const disposed: Array<string> = [] const disposed: Array<string> = []
yield* registerDisposerScoped((directory) => { yield* registerDisposerScoped((directory) => {
disposed.push(directory) disposed.push(directory)
Deferred.doneUnsafe(disposing, Effect.void) Deferred.doneUnsafe(disposing, Effect.void)
return new Promise<void>((resolve) => { return new Promise<void>((resolve) => {
Queue.offerUnsafe(releaseDispose, resolve) Deferred.doneUnsafe(releaseDispose, Effect.succeed(resolve))
}) })
}) })
yield* store.load({ directory: dir }) yield* store.load({ directory: dir })
const first = yield* store.disposeAll().pipe(Effect.forkScoped) const first = yield* store.disposeAll().pipe(Effect.forkScoped)
yield* Deferred.await(disposing) yield* Deferred.await(disposing)
const release = yield* Queue.take(releaseDispose) const release = yield* Deferred.await(releaseDispose)
const second = yield* store.disposeAll().pipe(Effect.forkScoped) const second = yield* store.disposeAll().pipe(Effect.forkScoped)
expect(disposed).toEqual([dir]) expect(disposed).toEqual([dir])