chore: generate
This commit is contained in:
@@ -269,10 +269,7 @@ it.live("InstanceState correct after interleaved init and dispose", () =>
|
|||||||
expect(a).toBe(one)
|
expect(a).toBe(one)
|
||||||
|
|
||||||
const [, b] = yield* Effect.all(
|
const [, b] = yield* Effect.all(
|
||||||
[
|
[reloadInstance({ directory: one }), Test.use((svc) => svc.get()).pipe(provideInstanceEffect(two))],
|
||||||
reloadInstance({ directory: one }),
|
|
||||||
Test.use((svc) => svc.get()).pipe(provideInstanceEffect(two)),
|
|
||||||
],
|
|
||||||
{ concurrency: "unbounded" },
|
{ concurrency: "unbounded" },
|
||||||
)
|
)
|
||||||
expect(b).toBe(two)
|
expect(b).toBe(two)
|
||||||
|
|||||||
@@ -18,9 +18,7 @@ import { TestLLMServer } from "../lib/llm-server"
|
|||||||
|
|
||||||
const noopBootstrap = Layer.succeed(InstanceBootstrap.Service, InstanceBootstrap.Service.of({ run: Effect.void }))
|
const noopBootstrap = Layer.succeed(InstanceBootstrap.Service, InstanceBootstrap.Service.of({ run: Effect.void }))
|
||||||
export const testInstanceStoreLayer = InstanceStore.defaultLayer.pipe(Layer.provide(noopBootstrap))
|
export const testInstanceStoreLayer = InstanceStore.defaultLayer.pipe(Layer.provide(noopBootstrap))
|
||||||
const testInstanceRuntime = ManagedRuntime.make(
|
const testInstanceRuntime = ManagedRuntime.make(testInstanceStoreLayer.pipe(Layer.provideMerge(Observability.layer)))
|
||||||
testInstanceStoreLayer.pipe(Layer.provideMerge(Observability.layer)),
|
|
||||||
)
|
|
||||||
|
|
||||||
const runTestInstanceStore = <A>(fn: (store: InstanceStore.Interface) => Effect.Effect<A>) =>
|
const runTestInstanceStore = <A>(fn: (store: InstanceStore.Interface) => Effect.Effect<A>) =>
|
||||||
testInstanceRuntime.runPromise(InstanceStore.Service.use(fn))
|
testInstanceRuntime.runPromise(InstanceStore.Service.use(fn))
|
||||||
@@ -207,10 +205,7 @@ export const withTmpdirInstance =
|
|||||||
Effect.gen(function* () {
|
Effect.gen(function* () {
|
||||||
const directory = yield* tmpdirScoped(options)
|
const directory = yield* tmpdirScoped(options)
|
||||||
return yield* self.pipe(Effect.provideService(TestInstance, { directory }), provideInstanceEffect(directory))
|
return yield* self.pipe(Effect.provideService(TestInstance, { directory }), provideInstanceEffect(directory))
|
||||||
}).pipe(
|
}).pipe(Effect.provide(testInstanceStoreLayer), Effect.provide(CrossSpawnSpawner.defaultLayer))
|
||||||
Effect.provide(testInstanceStoreLayer),
|
|
||||||
Effect.provide(CrossSpawnSpawner.defaultLayer),
|
|
||||||
)
|
|
||||||
|
|
||||||
export function provideTmpdirServer<A, E, R>(
|
export function provideTmpdirServer<A, E, R>(
|
||||||
self: (input: { dir: string; llm: TestLLMServer["Service"] }) => Effect.Effect<A, E, R>,
|
self: (input: { dir: string; llm: TestLLMServer["Service"] }) => Effect.Effect<A, E, R>,
|
||||||
|
|||||||
Reference in New Issue
Block a user