support global streamid, bump to 0.6.1

replit · Dec 3, 2023 · 079dec3 · 079dec3
1 parent 40827af
commit 079dec3
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -2,7 +2,7 @@
   "name": "@replit/river",
   "sideEffects": false,
   "description": "It's like tRPC but... with JSON Schema Support, duplex streaming and support for service multiplexing. Transport agnostic!",
-  "version": "0.6.0",
+  "version": "0.6.1",
   "type": "module",
   "exports": {
     ".": "./dist/router/index.js",

diff --git a/router/client.ts b/router/client.ts
@@ -117,9 +117,9 @@ export const createClient = <Srv extends Server<Record<string, AnyService>>>(
 
     function belongsToSameStream(msg: OpaqueTransportMessage) {
       return (
-        msg.streamId === streamId &&
         msg.serviceName === serviceName &&
-        msg.procedureName === procName
+        msg.procedureName === procName &&
+        (msg.streamId === streamId || msg.streamId === 'global')
       );
     }