feat: implement RFC-7

.vscode/launch.json

@@ -35,7 +35,7 @@
         "${workspaceRoot}/node_modules/.bin/jest",
         "--runInBand",
         "--coverage",
-        "test/push-channel.spec.ts"
+        "test/codegen-server.spec.ts"
       ],
       "console": "integratedTerminal",
       "internalConsoleOptions": "neverOpen",

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+  "typescript.tsdk": "node_modules/typescript/lib"
+}

etc/rpc.api.md

@@ -14,10 +14,10 @@ export type AsyncProcedureResultClient = Promise<Uint8Array | AsyncGenerator<Uin
 export type AsyncProcedureResultServer = Promise<Uint8Array | void> | AsyncGenerator<Uint8Array>;
 
 // @public (undocumented)
-export type CallableProcedureClient = (payload: Uint8Array) => AsyncProcedureResultClient;
+export type CallableProcedureClient = (payload: Uint8Array | AsyncIterable<Uint8Array>) => AsyncProcedureResultClient;
 
 // @public (undocumented)
-export type CallableProcedureServer<Context> = (payload: Uint8Array, context: Context) => AsyncProcedureResultServer;
+export type CallableProcedureServer<Context> = (payload: Uint8Array | AsyncIterable<Uint8Array>, context: Context) => AsyncProcedureResultServer;
 
 // @public (undocumented)
 export type ClientModuleDefinition = Record<string, CallableProcedureClient>;
@@ -88,7 +88,7 @@ export type RpcServerPort<Context> = Pick<Emitter<RpcPortEvents>, "on" | "emit">
     readonly portName: string;
     registerModule(moduleName: string, moduleDefinition: ModuleGeneratorFunction<Context>): void;
     loadModule(moduleName: string): Promise<ServerModuleDeclaration<any>>;
-    callProcedure(procedureId: number, argument: Uint8Array, context: Context): AsyncProcedureResultServer;
+    callProcedure(procedureId: number, argument: Uint8Array | AsyncIterable<Uint8Array>, context: Context): AsyncProcedureResultServer;
     close(): void;
 };
 
@@ -113,6 +113,9 @@ export type ServerModuleProcedure<Context> = {
     callable: CallableProcedureServer<Context>;
 };
 
+// @public (undocumented)
+export function streamWithoutAck<T extends object>(args: T): T;
+
 // @public (undocumented)
 export type Transport = Pick<Emitter<TransportEvents>, "on" | "emit"> & {
     sendMessage(message: Uint8Array): void;

example/api.proto

@@ -17,4 +17,6 @@ message QueryBooksRequest {
 service BookService {
   rpc GetBook(GetBookRequest) returns (Book) {}
   rpc QueryBooks(QueryBooksRequest) returns (stream Book) {}
+  rpc GetBookStream(stream GetBookRequest) returns (Book) {}
+  rpc QueryBooksStream(stream GetBookRequest) returns (stream Book) {}
 }