From 5905eee47d5239a04153e1c6ffff60e95574712b Mon Sep 17 00:00:00 2001
From: Tim <hello@timsmart.co>
Date: Sat, 1 Feb 2025 16:59:47 +1300
Subject: [PATCH] add liveSleep before GetInterrupts

---
 packages/rpc/test/RpcServer.test.ts | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/packages/rpc/test/RpcServer.test.ts b/packages/rpc/test/RpcServer.test.ts
index e8fe159f1c..76082dadd1 100644
--- a/packages/rpc/test/RpcServer.test.ts
+++ b/packages/rpc/test/RpcServer.test.ts
@@ -5,6 +5,11 @@ import { Rpc, RpcClient, RpcGroup, RpcMiddleware, RpcSchema, RpcSerialization, R
 import { assert, describe, it } from "@effect/vitest"
 import { Context, Effect, Layer, Mailbox, Schema, Stream, TestClock } from "effect"
 
+const liveSleep = (ms: number) =>
+  Effect.async<void>((resume) => {
+    setTimeout(() => resume(Effect.void), ms)
+  })
+
 describe("RpcServer", () => {
   const e2eSuite = <E>(name: string, layer: Layer.Layer<UsersClient, E>) => {
     describe.concurrent(name, () => {
@@ -42,14 +47,13 @@ describe("RpcServer", () => {
           )
 
           // wait for socket to connect
-          yield* Effect.async<void>((resume) => {
-            setTimeout(() => resume(Effect.void), 100)
-          })
+          yield* liveSleep(100)
           yield* TestClock.adjust(1000)
           assert.deepStrictEqual(users, [new User({ id: "1", name: "John" })])
           yield* TestClock.adjust(4000)
           assert.lengthOf(users, 5)
 
+          yield* liveSleep(100)
           const interrupts = yield* client.GetInterrupts({})
           assert.equal(interrupts, 1)
         }).pipe(Effect.provide(layer)))