small type updates: unexport unwrapOrThrow, add regression test for ctx.cancel return

__tests__/typescript-stress.test.ts

@@ -234,7 +234,33 @@ const services = {
       requestInit: Type.Object({}),
       requestData: Type.Object({ n: Type.Number() }),
       responseData: Type.Object({ n: Type.Number() }),
-      async handler() {
+      responseError: flattenErrorType(
+        Type.Union([
+          Type.Object({
+            code: Type.Literal('ERROR1'),
+            message: Type.String(),
+          }),
+          Type.Object({
+            code: Type.Literal('ERROR2'),
+            message: Type.String(),
+          }),
+        ]),
+      ),
+      async handler({ ctx, reqReadable }) {
+        for await (const { ok, payload } of reqReadable) {
+          if (!ok) {
+            return ctx.cancel();
+          }
+
+          if (payload.n === 1) {
+            return Err({ code: 'ERROR1', message: 'n is 1' });
+          }
+
+          if (payload.n === 2) {
+            return Err({ code: 'ERROR2', message: 'n is 2' });
+          }
+        }
+
         return Ok({ n: 1 });
       },
     }),

package.json

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

router/index.ts

@@ -49,7 +49,7 @@ export type {
   ServiceContext,
   ProcedureHandlerContext,
 } from './context';
-export { Ok, Err, unwrapOrThrow } from './result';
+export { Ok, Err } from './result';
 export type {
   Result,
   ErrResult,