Skip to content

Commit 2825718

Browse files
committed
fix: extend effect rpc ping timeout
1 parent f61fa94 commit 2825718

2 files changed

Lines changed: 120 additions & 119 deletions

File tree

patches/effect@4.0.0-beta.78.patch

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -298,7 +298,8 @@ index a3161eb..0cb81f3 100644
298298
recievedPong = false;
299299
- return writePing;
300300
+ return (hooks?.onPing ?? Effect.void).pipe(Effect.andThen(writePing));
301-
}).pipe(Effect.delay("5 seconds"), Effect.ignore, Effect.forever, Effect.interruptible, Effect.forkScoped);
301+
- }).pipe(Effect.delay("5 seconds"), Effect.ignore, Effect.forever, Effect.interruptible, Effect.forkScoped);
302+
+ }).pipe(Effect.delay("60 seconds"), Effect.ignore, Effect.forever, Effect.interruptible, Effect.forkScoped);
302303
return {
303304
timeout: latch.await,
304305
@@ -820,6 +849,11 @@ export const makeProtocolWorker = options => Protocol.make(Effect.fnUntraced(fun

0 commit comments

Comments
 (0)