@replit/river - npm Package Compare versions

Comparing version 0.200.0-rc.9 to 0.200.0-rc.10

dist/router/index.d.ts

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

dist/router/index.js

@@ -33,3 +33,3 @@ import {
   version
-} from "../chunk-EETL2L77.js";
+} from "../chunk-B6JVGGZM.js";
 
@@ -36,0 +36,0 @@ // router/services.ts

dist/transport/impls/ws/client.js

 import {
   ClientTransport
-} from "../../../chunk-4HT6P2ZG.js";
+} from "../../../chunk-6L6S2R44.js";
 import {
   WebSocketConnection
-} from "../../../chunk-GR3AQKHL.js";
-import "../../../chunk-I75XYO5W.js";
+} from "../../../chunk-GZJBYYHE.js";
+import "../../../chunk-UAJT22KM.js";
 import "../../../chunk-VXYHC666.js";
-import "../../../chunk-42Z2FQIU.js";
-import "../../../chunk-EETL2L77.js";
+import "../../../chunk-6N4GLYYL.js";
+import "../../../chunk-B6JVGGZM.js";
 import "../../../chunk-4PVU7J25.js";
@@ -12,0 +12,0 @@

dist/transport/impls/ws/server.js

 import {
   ServerTransport
-} from "../../../chunk-ZXZE253M.js";
+} from "../../../chunk-2E7ILLZ7.js";
 import {
   WebSocketConnection
-} from "../../../chunk-GR3AQKHL.js";
-import "../../../chunk-I75XYO5W.js";
+} from "../../../chunk-GZJBYYHE.js";
+import "../../../chunk-UAJT22KM.js";
 import "../../../chunk-VXYHC666.js";
-import "../../../chunk-42Z2FQIU.js";
-import "../../../chunk-EETL2L77.js";
+import "../../../chunk-6N4GLYYL.js";
+import "../../../chunk-B6JVGGZM.js";
 import "../../../chunk-4PVU7J25.js";
@@ -12,0 +12,0 @@

dist/transport/index.js

 import {
   ClientTransport
-} from "../chunk-4HT6P2ZG.js";
+} from "../chunk-6L6S2R44.js";
 import {
   ServerTransport
-} from "../chunk-ZXZE253M.js";
+} from "../chunk-2E7ILLZ7.js";
 import {
@@ -11,11 +11,11 @@ Connection,
   Transport
-} from "../chunk-I75XYO5W.js";
+} from "../chunk-UAJT22KM.js";
 import "../chunk-VXYHC666.js";
 import {
   SessionState
-} from "../chunk-42Z2FQIU.js";
+} from "../chunk-6N4GLYYL.js";
 import {
   OpaqueTransportMessageSchema,
   TransportMessageSchema
-} from "../chunk-EETL2L77.js";
+} from "../chunk-B6JVGGZM.js";
 import "../chunk-4PVU7J25.js";
@@ -22,0 +22,0 @@ export {

dist/util/testHelpers.d.ts

@@ -77,6 +77,6 @@ import { T as Transport, C as Connection, m as SessionOptions, n as ClientTransportOptions, e as SessionNoConnection, o as ServiceContext, S as Session } from '../context-b4aff18f.js';
 };
-declare function asClientUpload<State extends object, Init extends PayloadType, Input extends PayloadType, Output extends PayloadType, Err extends ProcedureErrorSchemaType>(state: State, proc: Procedure<State, 'upload', Init, Input, Output, Err>, reqInit?: Static<Init>, extendedContext?: Omit<ServiceContext, 'state'>, session?: Session<Connection>): [
-    WriteStream<Static<Input>>,
-    () => Promise<Result<Static<Output>, Static<Err>>>
-];
+declare function asClientUpload<State extends object, Init extends PayloadType, Input extends PayloadType, Output extends PayloadType, Err extends ProcedureErrorSchemaType>(state: State, proc: Procedure<State, 'upload', Init, Input, Output, Err>, reqInit?: Static<Init>, extendedContext?: Omit<ServiceContext, 'state'>, session?: Session<Connection>): {
+    reqWriter: WriteStream<Static<Input>>;
+    finalize: () => Promise<Result<Static<Output>, Static<Err>>>;
+};
 declare function getTransportConnections<ConnType extends Connection>(transport: Transport<ConnType>): Array<ConnType>;
@@ -83,0 +83,0 @@ declare function numberOfConnections<ConnType extends Connection>(transport: Transport<ConnType>): number;

dist/util/testHelpers.js

@@ -12,7 +12,7 @@ import {
   defaultTransportOptions
-} from "../chunk-42Z2FQIU.js";
+} from "../chunk-6N4GLYYL.js";
 import {
   coerceErrorString,
   currentProtocolVersion
-} from "../chunk-EETL2L77.js";
+} from "../chunk-B6JVGGZM.js";
 import "../chunk-4PVU7J25.js";
@@ -182,3 +182,3 @@
   }).catch(catchProcError);
-  return [requestPipe.writer, () => result];
+  return { reqWriter: requestPipe.writer, finalize: () => result };
 }
@@ -185,0 +185,0 @@ function getTransportConnections(transport) {

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.9",
+  "version": "0.200.0-rc.10",
   "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

1568479

increased by0.01%

No dependency changes