ensure rpc chunks are always delimited on write (#3710)

Effect-TS · Oct 1, 2024 · dc14e96 · dc14e96
1 parent 16fe968
commit dc14e96
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/.changeset/wicked-singers-refuse.md b/.changeset/wicked-singers-refuse.md
@@ -0,0 +1,5 @@
+---
+"@effect/rpc-http": patch
+---
+
+ensure rpc chunks are always delimited on write
diff --git a/packages/rpc-http/src/HttpRpcRouter.ts b/packages/rpc-http/src/HttpRpcRouter.ts
@@ -28,8 +28,7 @@ export const toHttpApp = <R extends Router.RpcRouter<any, any>>(self: R): App.De
       ServerResponse.stream(
         handler(_).pipe(
           Stream.chunks,
-          Stream.map((_) => JSON.stringify(Chunk.toArray(_))),
-          Stream.intersperse("\n"),
+          Stream.map((_) => JSON.stringify(Chunk.toReadonlyArray(_)) + "\n"),
           Stream.encodeText,
           Stream.provideContext(context)
         ),