@replit/river - npm Package Compare versions

Comparing version 0.200.4 to 0.200.5

dist/router/index.d.ts

@@ -58,4 +58,4 @@ import { A as AnyServiceSchemaMap, I as InstantiatedServiceSchemaMap, g as AnyProcedure } from '../services-94e0afc3.js';
 
-var version = "0.200.4";
+var version = "0.200.5";
 
 export { ParsedMetadata, version as RIVER_VERSION, Server, ServiceContext, createServer };

dist/router/index.js

@@ -30,3 +30,3 @@ import {
   version
-} from "../chunk-Q7DD2FLX.js";
+} from "../chunk-64J442AK.js";
 
@@ -719,7 +719,6 @@ // router/services.ts
       }
-      const newStream = this.createNewProcStream({
+      this.createNewProcStream({
         ...newStreamProps,
         ...message
       });
-      this.streams.set(streamId, newStream);
     };
@@ -857,2 +856,3 @@ const handleSessionStatus = (evt) => {
     };
+    const finishedController = new AbortController();
     const procStream = {
@@ -899,3 +899,2 @@ from,
     };
-    const finishedController = new AbortController();
     const cleanup = () => {
@@ -975,4 +974,2 @@ finishedController.abort();
       closeReadable();
-    } else if (procedure.type === "rpc" || procedure.type === "subscription") {
-      this.log?.warn("sent an init without a stream close", loggingMetadata);
     }
@@ -1090,3 +1087,5 @@ const handlerContext = {
     }
-    return procStream;
+    if (!finishedController.signal.aborted) {
+      this.streams.set(streamId, procStream);
+    }
   }
@@ -1093,0 +1092,0 @@ getContext(service, serviceName) {

dist/transport/impls/ws/client.js

 import {
   ClientTransport
-} from "../../../chunk-GKBNAMHM.js";
+} from "../../../chunk-WN7GEBMX.js";
 import {
   WebSocketConnection
-} from "../../../chunk-BBTXTDJ5.js";
-import "../../../chunk-RWVZCH26.js";
+} from "../../../chunk-Z7Q5CDXD.js";
+import "../../../chunk-7Z5MSOKL.js";
 import "../../../chunk-LHH5LQ7C.js";
-import "../../../chunk-LL4CB5UD.js";
-import "../../../chunk-Q7DD2FLX.js";
+import "../../../chunk-3FMY7VTM.js";
+import "../../../chunk-64J442AK.js";
 import "../../../chunk-AJGIY2UB.js";
@@ -12,0 +12,0 @@

dist/transport/impls/ws/server.js

 import {
   ServerTransport
-} from "../../../chunk-6EORIAZJ.js";
+} from "../../../chunk-MSJGPQRT.js";
 import {
   WebSocketConnection
-} from "../../../chunk-BBTXTDJ5.js";
-import "../../../chunk-RWVZCH26.js";
+} from "../../../chunk-Z7Q5CDXD.js";
+import "../../../chunk-7Z5MSOKL.js";
 import "../../../chunk-LHH5LQ7C.js";
-import "../../../chunk-LL4CB5UD.js";
-import "../../../chunk-Q7DD2FLX.js";
+import "../../../chunk-3FMY7VTM.js";
+import "../../../chunk-64J442AK.js";
 import "../../../chunk-AJGIY2UB.js";
@@ -12,0 +12,0 @@

dist/transport/index.js

 import {
   ClientTransport
-} from "../chunk-GKBNAMHM.js";
+} from "../chunk-WN7GEBMX.js";
 import {
   ServerTransport
-} from "../chunk-6EORIAZJ.js";
+} from "../chunk-MSJGPQRT.js";
 import {
@@ -11,11 +11,11 @@ Connection,
   Transport
-} from "../chunk-RWVZCH26.js";
+} from "../chunk-7Z5MSOKL.js";
 import "../chunk-LHH5LQ7C.js";
 import {
   SessionState
-} from "../chunk-LL4CB5UD.js";
+} from "../chunk-3FMY7VTM.js";
 import {
   OpaqueTransportMessageSchema,
   TransportMessageSchema
-} from "../chunk-Q7DD2FLX.js";
+} from "../chunk-64J442AK.js";
 import "../chunk-AJGIY2UB.js";
@@ -22,0 +22,0 @@ export {

dist/util/testHelpers.js

@@ -12,7 +12,7 @@ import {
   defaultTransportOptions
-} from "../chunk-LL4CB5UD.js";
+} from "../chunk-3FMY7VTM.js";
 import {
   coerceErrorString,
   currentProtocolVersion
-} from "../chunk-Q7DD2FLX.js";
+} from "../chunk-64J442AK.js";
 import "../chunk-AJGIY2UB.js";
@@ -19,0 +19,0 @@

package.json

 {
   "name": "@replit/river",
   "description": "It's like tRPC but... with JSON Schema Support, duplex streaming and support for service multiplexing. Transport agnostic!",
-  "version": "0.200.4",
+  "version": "0.200.5",
   "type": "module",
@@ -6,0 +6,0 @@ "exports": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

1571094

decreased by-0.07%

Lines of code

16141

decreased by-0.01%

No dependency changes