ci: merge staging to master

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@matrixai/rpc",
-  "version": "0.1.2",
+  "version": "0.1.5",
   "author": "Matrix AI",
   "contributors": [
     {

src/handlers/ClientHandler.ts

@@ -8,12 +8,12 @@ abstract class ClientHandler<
   Input extends JSONValue = JSONValue,
   Output extends JSONValue = JSONValue,
 > extends Handler<Container, Input, Output> {
-  public handle = async (
+  public handle = async function* (
     input: AsyncIterableIterator<Input>,
     cancel: (reason?: any) => void,
     meta: Record<string, JSONValue> | undefined,
     ctx: ContextTimed,
-  ): Promise<Output> => {
+  ): AsyncIterableIterator<Output> {
     throw new ErrorRPCMethodNotImplemented();
   };
 }

src/handlers/RawHandler.ts

@@ -6,13 +6,16 @@ import { ErrorRPCMethodNotImplemented } from '../errors';
 
 abstract class RawHandler<
   Container extends ContainerType = ContainerType,
+  Input extends JSONValue = JSONValue, // Define Input type if needed
+  Output extends JSONValue = JSONValue, // Define Output type if needed
 > extends Handler<Container> {
-  public handle = async (
-    input: [JSONRPCRequest, ReadableStream<Uint8Array>],
+  public handle = async function* (
+    input: AsyncIterableIterator<Input>, // Change this based on your specific needs
     cancel: (reason?: any) => void,
     meta: Record<string, JSONValue> | undefined,
     ctx: ContextTimed,
-  ): Promise<[JSONValue, ReadableStream<Uint8Array>]> => {
+  ): AsyncIterableIterator<Output> {
+    // Change return type to AsyncIterableIterator
     throw new ErrorRPCMethodNotImplemented('This method must be overridden');
   };
 }

src/handlers/UnaryHandler.ts

@@ -8,12 +8,12 @@ abstract class UnaryHandler<
   Input extends JSONValue = JSONValue,
   Output extends JSONValue = JSONValue,
 > extends Handler<Container, Input, Output> {
-  public handle = async (
+  public handle = async function* (
     input: Input,
     cancel: (reason?: any) => void,
     meta: Record<string, JSONValue> | undefined,
     ctx: ContextTimed,
-  ): Promise<Output> => {
+  ): AsyncIterableIterator<Output> {
     throw new ErrorRPCMethodNotImplemented('This method must be overridden');
   };
 }

src/types.ts

@@ -200,11 +200,8 @@ type ContainerType = Record<string, any>;
  * mainly used as the return type for the `StreamFactory`. But the interface
  * can be propagated across the RPC system.
  */
-interface RPCStream<
-  R,
-  W,
-  M extends Record<string, JSONValue> = Record<string, JSONValue>,
-> extends ReadableWritablePair<R, W> {
+interface RPCStream<R, W, M extends POJO = POJO>
+  extends ReadableWritablePair<R, W> {
   cancel: (reason?: any) => void;
   meta?: M;
 }