test: deflake 'cancel interrupts....' test
This commit is contained in:
parent
a740d2c667
commit
f0bd70b2e9
1 changed files with 10 additions and 2 deletions
|
|
@ -115,8 +115,16 @@ describe("Runner", () => {
|
||||||
Effect.gen(function* () {
|
Effect.gen(function* () {
|
||||||
const s = yield* Scope.Scope
|
const s = yield* Scope.Scope
|
||||||
const runner = Runner.make<string>(s)
|
const runner = Runner.make<string>(s)
|
||||||
const fiber = yield* runner.ensureRunning(Effect.never.pipe(Effect.as("never"))).pipe(Effect.forkChild)
|
const started = yield* Deferred.make<void>()
|
||||||
yield* Effect.sleep("10 millis")
|
const fiber = yield* runner
|
||||||
|
.ensureRunning(
|
||||||
|
Effect.gen(function* () {
|
||||||
|
yield* Deferred.succeed(started, undefined)
|
||||||
|
return yield* Effect.never.pipe(Effect.as("never"))
|
||||||
|
}),
|
||||||
|
)
|
||||||
|
.pipe(Effect.forkChild)
|
||||||
|
yield* Deferred.await(started)
|
||||||
expect(runner.busy).toBe(true)
|
expect(runner.busy).toBe(true)
|
||||||
expect(runner.state._tag).toBe("Running")
|
expect(runner.state._tag).toBe("Running")
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue