@replit/river
Advanced tools
Comparing version 0.6.0 to 0.6.1
@@ -42,5 +42,5 @@ import { pushable } from 'it-pushable'; | ||
function belongsToSameStream(msg) { | ||
return (msg.streamId === streamId && | ||
msg.serviceName === serviceName && | ||
msg.procedureName === procName); | ||
return (msg.serviceName === serviceName && | ||
msg.procedureName === procName && | ||
(msg.streamId === streamId || msg.streamId === 'global')); | ||
} | ||
@@ -47,0 +47,0 @@ if (input === undefined) { |
@@ -5,3 +5,3 @@ { | ||
"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", | ||
@@ -8,0 +8,0 @@ "exports": { |
@@ -8,2 +8,11 @@ # river - Streaming Remote Procedure Calls | ||
- with support for service multiplexing | ||
- with Result types and error handling | ||
- over WebSockets | ||
## Developing | ||
- `npm i` -- install dependencies | ||
- `npm check` -- lint | ||
- `npm format` -- format | ||
- `npm test` -- run tests | ||
- `npm publish` -- cut a new release (should bump version in package.json first) |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
203686
18