chore: generate
This commit is contained in:
@@ -999,7 +999,9 @@ it.live("pending permission rejects on instance dispose", () =>
|
|||||||
}).pipe(run, Effect.forkScoped)
|
}).pipe(run, Effect.forkScoped)
|
||||||
|
|
||||||
expect(yield* waitForPending(1).pipe(run)).toHaveLength(1)
|
expect(yield* waitForPending(1).pipe(run)).toHaveLength(1)
|
||||||
yield* Effect.promise(() => Instance.provide({ directory: dir, fn: () => void InstanceStore.disposeInstance(Instance.current) }))
|
yield* Effect.promise(() =>
|
||||||
|
Instance.provide({ directory: dir, fn: () => void InstanceStore.disposeInstance(Instance.current) }),
|
||||||
|
)
|
||||||
|
|
||||||
const exit = yield* Fiber.await(fiber)
|
const exit = yield* Fiber.await(fiber)
|
||||||
expect(Exit.isFailure(exit)).toBe(true)
|
expect(Exit.isFailure(exit)).toBe(true)
|
||||||
|
|||||||
@@ -137,7 +137,11 @@ describe("Worktree", () => {
|
|||||||
expect(props.name).toBe(info.name)
|
expect(props.name).toBe(info.name)
|
||||||
expect(props.branch).toBe(info.branch)
|
expect(props.branch).toBe(info.branch)
|
||||||
|
|
||||||
yield* Effect.promise(() => InstanceStore.runtime.runPromise((s) => s.load({ directory: info.directory }).pipe(Effect.flatMap(s.dispose))))
|
yield* Effect.promise(() =>
|
||||||
|
InstanceStore.runtime.runPromise((s) =>
|
||||||
|
s.load({ directory: info.directory }).pipe(Effect.flatMap(s.dispose)),
|
||||||
|
),
|
||||||
|
)
|
||||||
yield* Effect.promise(() => Bun.sleep(100))
|
yield* Effect.promise(() => Bun.sleep(100))
|
||||||
yield* svc.remove({ directory: info.directory })
|
yield* svc.remove({ directory: info.directory })
|
||||||
}),
|
}),
|
||||||
@@ -157,7 +161,11 @@ describe("Worktree", () => {
|
|||||||
expect(info.branch).toBe("opencode/test-workspace")
|
expect(info.branch).toBe("opencode/test-workspace")
|
||||||
|
|
||||||
yield* Effect.promise(() => ready)
|
yield* Effect.promise(() => ready)
|
||||||
yield* Effect.promise(() => InstanceStore.runtime.runPromise((s) => s.load({ directory: info.directory }).pipe(Effect.flatMap(s.dispose))))
|
yield* Effect.promise(() =>
|
||||||
|
InstanceStore.runtime.runPromise((s) =>
|
||||||
|
s.load({ directory: info.directory }).pipe(Effect.flatMap(s.dispose)),
|
||||||
|
),
|
||||||
|
)
|
||||||
yield* Effect.promise(() => Bun.sleep(100))
|
yield* Effect.promise(() => Bun.sleep(100))
|
||||||
yield* svc.remove({ directory: info.directory })
|
yield* svc.remove({ directory: info.directory })
|
||||||
}),
|
}),
|
||||||
|
|||||||
@@ -58,7 +58,9 @@ function withMcpProject<A, E, R>(self: (dir: string) => Effect.Effect<A, E, R>)
|
|||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
yield* Effect.addFinalizer(() =>
|
yield* Effect.addFinalizer(() =>
|
||||||
Effect.promise(() => Instance.provide({ directory: dir, fn: () => InstanceStore.disposeInstance(Instance.current) })).pipe(Effect.ignore),
|
Effect.promise(() =>
|
||||||
|
Instance.provide({ directory: dir, fn: () => InstanceStore.disposeInstance(Instance.current) }),
|
||||||
|
).pipe(Effect.ignore),
|
||||||
)
|
)
|
||||||
|
|
||||||
return yield* self(dir).pipe(provideInstance(dir))
|
return yield* self(dir).pipe(provideInstance(dir))
|
||||||
|
|||||||
@@ -90,7 +90,9 @@ function withProviderProject<A, E, R>(self: (dir: string) => Effect.Effect<A, E,
|
|||||||
)
|
)
|
||||||
yield* writeProviderAuthPlugin(dir)
|
yield* writeProviderAuthPlugin(dir)
|
||||||
yield* Effect.addFinalizer(() =>
|
yield* Effect.addFinalizer(() =>
|
||||||
Effect.promise(() => Instance.provide({ directory: dir, fn: () => InstanceStore.disposeInstance(Instance.current) })).pipe(Effect.ignore),
|
Effect.promise(() =>
|
||||||
|
Instance.provide({ directory: dir, fn: () => InstanceStore.disposeInstance(Instance.current) }),
|
||||||
|
).pipe(Effect.ignore),
|
||||||
)
|
)
|
||||||
|
|
||||||
return yield* self(dir).pipe(provideInstance(dir))
|
return yield* self(dir).pipe(provideInstance(dir))
|
||||||
|
|||||||
Reference in New Issue
Block a user