@replit/river - npm Package Compare versions

Comparing version 0.10.13 to 0.11.0

dist/transport/impls/stdio/stdio.js

 import {
-  StreamConnection,
-  createDelimitedStream
-} from "../../../chunk-3MQETIGZ.js";
+  MessageFramer,
+  StreamConnection
+} from "../../../chunk-GKPT5YQE.js";
 import "../../../chunk-ORAG7IAU.js";
@@ -33,4 +33,4 @@ import {
     super(options.codec, clientId);
-    const delimStream = createDelimitedStream();
-    this.input = input.pipe(delimStream);
+    const framedMessageStream = MessageFramer.createFramedStream();
+    this.input = input.pipe(framedMessageStream);
     this.output = output;
@@ -47,3 +47,3 @@ let conn = void 0;
     const cleanup = () => {
-      delimStream.destroy();
+      framedMessageStream.destroy();
       if (conn) {
@@ -50,0 +50,0 @@ this.onDisconnect(conn);

dist/transport/impls/unixsocket/client.js

 import {
-  StreamConnection,
-  createDelimitedStream
-} from "../../../chunk-3MQETIGZ.js";
+  MessageFramer,
+  StreamConnection
+} from "../../../chunk-GKPT5YQE.js";
 import "../../../chunk-ORAG7IAU.js";
@@ -42,4 +42,4 @@ import "../../../chunk-WVT5QXMZ.js";
     const conn = new StreamConnection(this, to, sock);
-    const delimStream = createDelimitedStream();
-    sock.pipe(delimStream).on("data", (data) => {
+    const framedMessageStream = MessageFramer.createFramedStream();
+    sock.pipe(framedMessageStream).on("data", (data) => {
       const parsedMsg = this.parseMsg(data);
@@ -51,3 +51,3 @@ if (parsedMsg) {
     const cleanup = () => {
-      delimStream.destroy();
+      framedMessageStream.destroy();
       if (conn) {
@@ -54,0 +54,0 @@ this.onDisconnect(conn);

dist/transport/impls/unixsocket/server.js

 import {
-  StreamConnection,
-  createDelimitedStream
-} from "../../../chunk-3MQETIGZ.js";
+  MessageFramer,
+  StreamConnection
+} from "../../../chunk-GKPT5YQE.js";
 import "../../../chunk-ORAG7IAU.js";
@@ -35,4 +35,4 @@ import "../../../chunk-WVT5QXMZ.js";
     let conn = void 0;
-    const delimStream = createDelimitedStream();
-    sock.pipe(delimStream).on("data", (data) => {
+    const framedMessageStream = MessageFramer.createFramedStream();
+    sock.pipe(framedMessageStream).on("data", (data) => {
       const parsedMsg = this.parseMsg(data);
@@ -49,3 +49,3 @@ if (!parsedMsg) {
     const cleanup = () => {
-      delimStream.destroy();
+      framedMessageStream.destroy();
       if (conn) {
@@ -52,0 +52,0 @@ this.onDisconnect(conn);

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.10.13",
+  "version": "0.11.0",
   "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

297913

increased by0.47%

Lines of code

8163

increased by0.49%

No dependency changes