@replit/river - npm Package Compare versions

Comparing version 0.200.0-rc.19 to 0.200.0-rc.20

dist/router/index.d.ts

@@ -48,4 +48,4 @@ import { A as AnyServiceSchemaMap, I as InstantiatedServiceSchemaMap } from '../services-aa49a9fb.js';
 
-var version = "0.200.0-rc.19";
+var version = "0.200.0-rc.20";
 
 export { version as RIVER_VERSION, Server, ServiceContext, createServer };

dist/router/index.js

@@ -30,3 +30,3 @@ import {
   version
-} from "../chunk-PV2QRPZW.js";
+} from "../chunk-BYCR4VEM.js";
 
@@ -494,3 +494,9 @@ // router/services.ts
       span.addEvent("received response close");
-      closeReadable();
+      if (resReadable.isClosed()) {
+        transport.log?.error(
+          "received stream close but readable was already closed"
+        );
+      } else {
+        closeReadable();
+      }
     }
@@ -513,5 +519,5 @@ }
       );
+      closeReadable();
     }
     reqWritable.close();
-    closeReadable();
   }
@@ -518,0 +524,0 @@ abortSignal?.addEventListener("abort", onClientCancel);

dist/transport/impls/ws/client.js

 import {
   ClientTransport
-} from "../../../chunk-7EFY72FS.js";
+} from "../../../chunk-WKBWCRGN.js";
 import {
   WebSocketConnection
-} from "../../../chunk-SSOSCBGC.js";
-import "../../../chunk-UZVA75UW.js";
+} from "../../../chunk-DM5QR4HQ.js";
+import "../../../chunk-3HI3IJTL.js";
 import "../../../chunk-BAGOAJ3K.js";
-import "../../../chunk-J5BGY63N.js";
-import "../../../chunk-PV2QRPZW.js";
+import "../../../chunk-OLWVR5AB.js";
+import "../../../chunk-BYCR4VEM.js";
 import "../../../chunk-4PVU7J25.js";
@@ -12,0 +12,0 @@

dist/transport/impls/ws/server.js

 import {
   ServerTransport
-} from "../../../chunk-AI3Z2SVT.js";
+} from "../../../chunk-5L5RNZXH.js";
 import {
   WebSocketConnection
-} from "../../../chunk-SSOSCBGC.js";
-import "../../../chunk-UZVA75UW.js";
+} from "../../../chunk-DM5QR4HQ.js";
+import "../../../chunk-3HI3IJTL.js";
 import "../../../chunk-BAGOAJ3K.js";
-import "../../../chunk-J5BGY63N.js";
-import "../../../chunk-PV2QRPZW.js";
+import "../../../chunk-OLWVR5AB.js";
+import "../../../chunk-BYCR4VEM.js";
 import "../../../chunk-4PVU7J25.js";
@@ -12,0 +12,0 @@

dist/transport/index.js

 import {
   ClientTransport
-} from "../chunk-7EFY72FS.js";
+} from "../chunk-WKBWCRGN.js";
 import {
   ServerTransport
-} from "../chunk-AI3Z2SVT.js";
+} from "../chunk-5L5RNZXH.js";
 import {
@@ -11,11 +11,11 @@ Connection,
   Transport
-} from "../chunk-UZVA75UW.js";
+} from "../chunk-3HI3IJTL.js";
 import "../chunk-BAGOAJ3K.js";
 import {
   SessionState
-} from "../chunk-J5BGY63N.js";
+} from "../chunk-OLWVR5AB.js";
 import {
   OpaqueTransportMessageSchema,
   TransportMessageSchema
-} from "../chunk-PV2QRPZW.js";
+} from "../chunk-BYCR4VEM.js";
 import "../chunk-4PVU7J25.js";
@@ -22,0 +22,0 @@ export {

dist/util/testHelpers.js

@@ -12,7 +12,7 @@ import {
   defaultTransportOptions
-} from "../chunk-J5BGY63N.js";
+} from "../chunk-OLWVR5AB.js";
 import {
   coerceErrorString,
   currentProtocolVersion
-} from "../chunk-PV2QRPZW.js";
+} from "../chunk-BYCR4VEM.js";
 import "../chunk-4PVU7J25.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.0-rc.19",
+  "version": "0.200.0-rc.20",
   "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

Improved metrics

Total package byte prevSize

1551042

increased by0.1%

Lines of code

15792

increased by0.13%

No dependency changes