feat: add common HandleStreamFunc

Signed-off-by: Christian Stewart <[email protected]>

Author: paralin

echo/echo.pb.ts

@@ -2,10 +2,10 @@
 // @generated from file github.com/aperturerobotics/starpc/echo/echo.proto (package echo, syntax proto3)
 /* eslint-disable */
 
-import type { MessageType, PartialFieldInfo } from "@aptre/protobuf-es-lite";
-import { createMessageType, ScalarType } from "@aptre/protobuf-es-lite";
+import type { MessageType, PartialFieldInfo } from '@aptre/protobuf-es-lite'
+import { createMessageType, ScalarType } from '@aptre/protobuf-es-lite'
 
-export const protobufPackage = "echo";
+export const protobufPackage = 'echo'
 
 /**
  * EchoMsg is the message body for Echo.
@@ -16,16 +16,14 @@ export interface EchoMsg {
   /**
    * @generated from field: string body = 1;
    */
-  body?: string;
-
-};
+  body?: string
+}
 
 // EchoMsg contains the message type declaration for EchoMsg.
 export const EchoMsg: MessageType<EchoMsg> = createMessageType({
-    typeName: "echo.EchoMsg",
-    fields: [
-        { no: 1, name: "body", kind: "scalar", T: ScalarType.STRING },
-    ] as readonly PartialFieldInfo[],
-    packedByDefault: true,
-});
-
+  typeName: 'echo.EchoMsg',
+  fields: [
+    { no: 1, name: 'body', kind: 'scalar', T: ScalarType.STRING },
+  ] as readonly PartialFieldInfo[],
+  packedByDefault: true,
+})

echo/echo_srpc.pb.ts

@@ -2,26 +2,31 @@
 // @generated from file github.com/aperturerobotics/starpc/echo/echo.proto (package echo, syntax proto3)
 /* eslint-disable */
 
-import { EchoMsg } from "./echo.pb.js";
-import { Empty, MethodKind } from "@aptre/protobuf-es-lite";
-import { RpcStreamPacket } from "../rpcstream/rpcstream.pb.js";
-import { buildDecodeMessageTransform, buildEncodeMessageTransform, MessageStream, ProtoRpc } from "starpc";
+import { EchoMsg } from './echo.pb.js'
+import { Empty, MethodKind } from '@aptre/protobuf-es-lite'
+import { RpcStreamPacket } from '../rpcstream/rpcstream.pb.js'
+import {
+  buildDecodeMessageTransform,
+  buildEncodeMessageTransform,
+  MessageStream,
+  ProtoRpc,
+} from 'starpc'
 
 /**
  * Echoer service returns the given message.
  *
  * @generated from service echo.Echoer
  */
 export const EchoerDefinition = {
-  typeName: "echo.Echoer",
+  typeName: 'echo.Echoer',
   methods: {
     /**
      * Echo returns the given message.
      *
      * @generated from rpc echo.Echoer.Echo
      */
     Echo: {
-      name: "Echo",
+      name: 'Echo',
       I: EchoMsg,
       O: EchoMsg,
       kind: MethodKind.Unary,
@@ -32,7 +37,7 @@ export const EchoerDefinition = {
      * @generated from rpc echo.Echoer.EchoServerStream
      */
     EchoServerStream: {
-      name: "EchoServerStream",
+      name: 'EchoServerStream',
       I: EchoMsg,
       O: EchoMsg,
       kind: MethodKind.ServerStreaming,
@@ -43,7 +48,7 @@ export const EchoerDefinition = {
      * @generated from rpc echo.Echoer.EchoClientStream
      */
     EchoClientStream: {
-      name: "EchoClientStream",
+      name: 'EchoClientStream',
       I: EchoMsg,
       O: EchoMsg,
       kind: MethodKind.ClientStreaming,
@@ -54,7 +59,7 @@ export const EchoerDefinition = {
      * @generated from rpc echo.Echoer.EchoBidiStream
      */
     EchoBidiStream: {
-      name: "EchoBidiStream",
+      name: 'EchoBidiStream',
       I: EchoMsg,
       O: EchoMsg,
       kind: MethodKind.BiDiStreaming,
@@ -65,7 +70,7 @@ export const EchoerDefinition = {
      * @generated from rpc echo.Echoer.RpcStream
      */
     RpcStream: {
-      name: "RpcStream",
+      name: 'RpcStream',
       I: RpcStreamPacket,
       O: RpcStreamPacket,
       kind: MethodKind.BiDiStreaming,
@@ -76,13 +81,13 @@ export const EchoerDefinition = {
      * @generated from rpc echo.Echoer.DoNothing
      */
     DoNothing: {
-      name: "DoNothing",
+      name: 'DoNothing',
       I: Empty,
       O: Empty,
       kind: MethodKind.Unary,
     },
-  }
-} as const;
+  },
+} as const
 
 /**
  * Echoer service returns the given message.
@@ -95,61 +100,54 @@ export interface Echoer {
    *
    * @generated from rpc echo.Echoer.Echo
    */
-  Echo(
-request: EchoMsg, abortSignal?: AbortSignal
-): 
-Promise<EchoMsg>
+  Echo(request: EchoMsg, abortSignal?: AbortSignal): Promise<EchoMsg>
 
   /**
    * EchoServerStream is an example of a server -> client one-way stream.
    *
    * @generated from rpc echo.Echoer.EchoServerStream
    */
   EchoServerStream(
-request: EchoMsg, abortSignal?: AbortSignal
-): 
-MessageStream<EchoMsg>
+    request: EchoMsg,
+    abortSignal?: AbortSignal,
+  ): MessageStream<EchoMsg>
 
   /**
    * EchoClientStream is an example of client->server one-way stream.
    *
    * @generated from rpc echo.Echoer.EchoClientStream
    */
   EchoClientStream(
-request: MessageStream<EchoMsg>, abortSignal?: AbortSignal
-): 
-Promise<EchoMsg>
+    request: MessageStream<EchoMsg>,
+    abortSignal?: AbortSignal,
+  ): Promise<EchoMsg>
 
   /**
    * EchoBidiStream is an example of a two-way stream.
    *
    * @generated from rpc echo.Echoer.EchoBidiStream
    */
   EchoBidiStream(
-request: MessageStream<EchoMsg>, abortSignal?: AbortSignal
-): 
-MessageStream<EchoMsg>
+    request: MessageStream<EchoMsg>,
+    abortSignal?: AbortSignal,
+  ): MessageStream<EchoMsg>
 
   /**
    * RpcStream opens a nested rpc call stream.
    *
    * @generated from rpc echo.Echoer.RpcStream
    */
   RpcStream(
-request: MessageStream<RpcStreamPacket>, abortSignal?: AbortSignal
-): 
-MessageStream<RpcStreamPacket>
+    request: MessageStream<RpcStreamPacket>,
+    abortSignal?: AbortSignal,
+  ): MessageStream<RpcStreamPacket>
 
   /**
    * DoNothing does nothing.
    *
    * @generated from rpc echo.Echoer.DoNothing
    */
-  DoNothing(
-request: Empty, abortSignal?: AbortSignal
-): 
-Promise<Empty>
-
+  DoNothing(request: Empty, abortSignal?: AbortSignal): Promise<Empty>
 }
 
 export const EchoerServiceName = EchoerDefinition.typeName
@@ -172,10 +170,7 @@ export class EchoerClient implements Echoer {
    *
    * @generated from rpc echo.Echoer.Echo
    */
-  async Echo(
-request: EchoMsg, abortSignal?: AbortSignal
-): 
-Promise<EchoMsg> {
+  async Echo(request: EchoMsg, abortSignal?: AbortSignal): Promise<EchoMsg> {
     const requestMsg = EchoMsg.create(request)
     const result = await this.rpc.request(
       this.service,
@@ -192,9 +187,9 @@ Promise<EchoMsg> {
    * @generated from rpc echo.Echoer.EchoServerStream
    */
   EchoServerStream(
-request: EchoMsg, abortSignal?: AbortSignal
-): 
-MessageStream<EchoMsg> {
+    request: EchoMsg,
+    abortSignal?: AbortSignal,
+  ): MessageStream<EchoMsg> {
     const requestMsg = EchoMsg.create(request)
     const result = this.rpc.serverStreamingRequest(
       this.service,
@@ -211,9 +206,9 @@ MessageStream<EchoMsg> {
    * @generated from rpc echo.Echoer.EchoClientStream
    */
   async EchoClientStream(
-request: MessageStream<EchoMsg>, abortSignal?: AbortSignal
-): 
-Promise<EchoMsg> {
+    request: MessageStream<EchoMsg>,
+    abortSignal?: AbortSignal,
+  ): Promise<EchoMsg> {
     const result = await this.rpc.clientStreamingRequest(
       this.service,
       EchoerDefinition.methods.EchoClientStream.name,
@@ -229,9 +224,9 @@ Promise<EchoMsg> {
    * @generated from rpc echo.Echoer.EchoBidiStream
    */
   EchoBidiStream(
-request: MessageStream<EchoMsg>, abortSignal?: AbortSignal
-): 
-MessageStream<EchoMsg> {
+    request: MessageStream<EchoMsg>,
+    abortSignal?: AbortSignal,
+  ): MessageStream<EchoMsg> {
     const result = this.rpc.bidirectionalStreamingRequest(
       this.service,
       EchoerDefinition.methods.EchoBidiStream.name,
@@ -247,9 +242,9 @@ MessageStream<EchoMsg> {
    * @generated from rpc echo.Echoer.RpcStream
    */
   RpcStream(
-request: MessageStream<RpcStreamPacket>, abortSignal?: AbortSignal
-): 
-MessageStream<RpcStreamPacket> {
+    request: MessageStream<RpcStreamPacket>,
+    abortSignal?: AbortSignal,
+  ): MessageStream<RpcStreamPacket> {
     const result = this.rpc.bidirectionalStreamingRequest(
       this.service,
       EchoerDefinition.methods.RpcStream.name,
@@ -264,10 +259,7 @@ MessageStream<RpcStreamPacket> {
    *
    * @generated from rpc echo.Echoer.DoNothing
    */
-  async DoNothing(
-request: Empty, abortSignal?: AbortSignal
-): 
-Promise<Empty> {
+  async DoNothing(request: Empty, abortSignal?: AbortSignal): Promise<Empty> {
     const requestMsg = Empty.create(request)
     const result = await this.rpc.request(
       this.service,
@@ -277,5 +269,4 @@ Promise<Empty> {
     )
     return Empty.fromBinary(result)
   }
-
 }