ci: merge staging to master

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@matrixai/rpc",
-  "version": "0.1.5",
+  "version": "0.1.6",
   "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 function* (
+  public handle = async (
     input: AsyncIterableIterator<Input>,
     cancel: (reason?: any) => void,
     meta: Record<string, JSONValue> | undefined,
     ctx: ContextTimed,
-  ): AsyncIterableIterator<Output> {
+  ): Promise<Output> => {
     throw new ErrorRPCMethodNotImplemented();
   };
 }

src/handlers/RawHandler.ts

@@ -6,16 +6,13 @@ 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 function* (
-    input: AsyncIterableIterator<Input>, // Change this based on your specific needs
+  public handle = async (
+    input: [JSONRPCRequest, ReadableStream<Uint8Array>],
     cancel: (reason?: any) => void,
     meta: Record<string, JSONValue> | undefined,
     ctx: ContextTimed,
-  ): AsyncIterableIterator<Output> {
-    // Change return type to AsyncIterableIterator
+  ): Promise<[JSONValue, ReadableStream<Uint8Array>]> => {
     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 function* (
+  public handle = async (
     input: Input,
     cancel: (reason?: any) => void,
     meta: Record<string, JSONValue> | undefined,
     ctx: ContextTimed,
-  ): AsyncIterableIterator<Output> {
+  ): Promise<Output> => {
     throw new ErrorRPCMethodNotImplemented('This method must be overridden');
   };
 }