2
2
// @generated from file github.com/aperturerobotics/starpc/echo/echo.proto (package echo, syntax proto3)
3
3
/* eslint-disable */
4
4
5
- import { EchoMsg } from './echo.pb.js'
6
- import { Empty , MethodKind } from '@aptre/protobuf-es-lite'
7
- import { RpcStreamPacket } from '../rpcstream/rpcstream.pb.js'
8
- import {
9
- buildDecodeMessageTransform ,
10
- buildEncodeMessageTransform ,
11
- MessageStream ,
12
- ProtoRpc ,
13
- } from 'starpc'
5
+ import { EchoMsg } from "./echo.pb.js" ;
6
+ import { Empty , MethodKind } from "@aptre/protobuf-es-lite" ;
7
+ import { RpcStreamPacket } from "../rpcstream/rpcstream.pb.js" ;
8
+ import { buildDecodeMessageTransform , buildEncodeMessageTransform , MessageStream , ProtoRpc } from "starpc" ;
14
9
15
10
/**
16
11
* Echoer service returns the given message.
17
12
*
18
13
* @generated from service echo.Echoer
19
14
*/
20
15
export const EchoerDefinition = {
21
- typeName : ' echo.Echoer' ,
16
+ typeName : " echo.Echoer" ,
22
17
methods : {
23
18
/**
24
19
* Echo returns the given message.
25
20
*
26
21
* @generated from rpc echo.Echoer.Echo
27
22
*/
28
23
Echo : {
29
- name : ' Echo' ,
24
+ name : " Echo" ,
30
25
I : EchoMsg ,
31
26
O : EchoMsg ,
32
27
kind : MethodKind . Unary ,
@@ -37,7 +32,7 @@ export const EchoerDefinition = {
37
32
* @generated from rpc echo.Echoer.EchoServerStream
38
33
*/
39
34
EchoServerStream : {
40
- name : ' EchoServerStream' ,
35
+ name : " EchoServerStream" ,
41
36
I : EchoMsg ,
42
37
O : EchoMsg ,
43
38
kind : MethodKind . ServerStreaming ,
@@ -48,7 +43,7 @@ export const EchoerDefinition = {
48
43
* @generated from rpc echo.Echoer.EchoClientStream
49
44
*/
50
45
EchoClientStream : {
51
- name : ' EchoClientStream' ,
46
+ name : " EchoClientStream" ,
52
47
I : EchoMsg ,
53
48
O : EchoMsg ,
54
49
kind : MethodKind . ClientStreaming ,
@@ -59,7 +54,7 @@ export const EchoerDefinition = {
59
54
* @generated from rpc echo.Echoer.EchoBidiStream
60
55
*/
61
56
EchoBidiStream : {
62
- name : ' EchoBidiStream' ,
57
+ name : " EchoBidiStream" ,
63
58
I : EchoMsg ,
64
59
O : EchoMsg ,
65
60
kind : MethodKind . BiDiStreaming ,
@@ -70,7 +65,7 @@ export const EchoerDefinition = {
70
65
* @generated from rpc echo.Echoer.RpcStream
71
66
*/
72
67
RpcStream : {
73
- name : ' RpcStream' ,
68
+ name : " RpcStream" ,
74
69
I : RpcStreamPacket ,
75
70
O : RpcStreamPacket ,
76
71
kind : MethodKind . BiDiStreaming ,
@@ -81,13 +76,13 @@ export const EchoerDefinition = {
81
76
* @generated from rpc echo.Echoer.DoNothing
82
77
*/
83
78
DoNothing : {
84
- name : ' DoNothing' ,
79
+ name : " DoNothing" ,
85
80
I : Empty ,
86
81
O : Empty ,
87
82
kind : MethodKind . Unary ,
88
83
} ,
89
- } ,
90
- } as const
84
+ }
85
+ } as const ;
91
86
92
87
/**
93
88
* Echoer service returns the given message.
@@ -100,54 +95,61 @@ export interface Echoer {
100
95
*
101
96
* @generated from rpc echo.Echoer.Echo
102
97
*/
103
- Echo ( request : EchoMsg , abortSignal ?: AbortSignal ) : Promise < EchoMsg >
98
+ Echo (
99
+ request : EchoMsg , abortSignal ?: AbortSignal
100
+ ) :
101
+ Promise < EchoMsg >
104
102
105
103
/**
106
104
* EchoServerStream is an example of a server -> client one-way stream.
107
105
*
108
106
* @generated from rpc echo.Echoer.EchoServerStream
109
107
*/
110
108
EchoServerStream (
111
- request : EchoMsg ,
112
- abortSignal ?: AbortSignal ,
113
- ) : MessageStream < EchoMsg >
109
+ request : EchoMsg , abortSignal ?: AbortSignal
110
+ ) :
111
+ MessageStream < EchoMsg >
114
112
115
113
/**
116
114
* EchoClientStream is an example of client->server one-way stream.
117
115
*
118
116
* @generated from rpc echo.Echoer.EchoClientStream
119
117
*/
120
118
EchoClientStream (
121
- request : MessageStream < EchoMsg > ,
122
- abortSignal ?: AbortSignal ,
123
- ) : Promise < EchoMsg >
119
+ request : MessageStream < EchoMsg > , abortSignal ?: AbortSignal
120
+ ) :
121
+ Promise < EchoMsg >
124
122
125
123
/**
126
124
* EchoBidiStream is an example of a two-way stream.
127
125
*
128
126
* @generated from rpc echo.Echoer.EchoBidiStream
129
127
*/
130
128
EchoBidiStream (
131
- request : MessageStream < EchoMsg > ,
132
- abortSignal ?: AbortSignal ,
133
- ) : MessageStream < EchoMsg >
129
+ request : MessageStream < EchoMsg > , abortSignal ?: AbortSignal
130
+ ) :
131
+ MessageStream < EchoMsg >
134
132
135
133
/**
136
134
* RpcStream opens a nested rpc call stream.
137
135
*
138
136
* @generated from rpc echo.Echoer.RpcStream
139
137
*/
140
138
RpcStream (
141
- request : MessageStream < RpcStreamPacket > ,
142
- abortSignal ?: AbortSignal ,
143
- ) : MessageStream < RpcStreamPacket >
139
+ request : MessageStream < RpcStreamPacket > , abortSignal ?: AbortSignal
140
+ ) :
141
+ MessageStream < RpcStreamPacket >
144
142
145
143
/**
146
144
* DoNothing does nothing.
147
145
*
148
146
* @generated from rpc echo.Echoer.DoNothing
149
147
*/
150
- DoNothing ( request : Empty , abortSignal ?: AbortSignal ) : Promise < Empty >
148
+ DoNothing (
149
+ request : Empty , abortSignal ?: AbortSignal
150
+ ) :
151
+ Promise < Empty >
152
+
151
153
}
152
154
153
155
export const EchoerServiceName = EchoerDefinition . typeName
@@ -170,7 +172,10 @@ export class EchoerClient implements Echoer {
170
172
*
171
173
* @generated from rpc echo.Echoer.Echo
172
174
*/
173
- async Echo ( request : EchoMsg , abortSignal ?: AbortSignal ) : Promise < EchoMsg > {
175
+ async Echo (
176
+ request : EchoMsg , abortSignal ?: AbortSignal
177
+ ) :
178
+ Promise < EchoMsg > {
174
179
const requestMsg = EchoMsg . create ( request )
175
180
const result = await this . rpc . request (
176
181
this . service ,
@@ -187,9 +192,9 @@ export class EchoerClient implements Echoer {
187
192
* @generated from rpc echo.Echoer.EchoServerStream
188
193
*/
189
194
EchoServerStream (
190
- request : EchoMsg ,
191
- abortSignal ?: AbortSignal ,
192
- ) : MessageStream < EchoMsg > {
195
+ request : EchoMsg , abortSignal ?: AbortSignal
196
+ ) :
197
+ MessageStream < EchoMsg > {
193
198
const requestMsg = EchoMsg . create ( request )
194
199
const result = this . rpc . serverStreamingRequest (
195
200
this . service ,
@@ -206,9 +211,9 @@ export class EchoerClient implements Echoer {
206
211
* @generated from rpc echo.Echoer.EchoClientStream
207
212
*/
208
213
async EchoClientStream (
209
- request : MessageStream < EchoMsg > ,
210
- abortSignal ?: AbortSignal ,
211
- ) : Promise < EchoMsg > {
214
+ request : MessageStream < EchoMsg > , abortSignal ?: AbortSignal
215
+ ) :
216
+ Promise < EchoMsg > {
212
217
const result = await this . rpc . clientStreamingRequest (
213
218
this . service ,
214
219
EchoerDefinition . methods . EchoClientStream . name ,
@@ -224,9 +229,9 @@ export class EchoerClient implements Echoer {
224
229
* @generated from rpc echo.Echoer.EchoBidiStream
225
230
*/
226
231
EchoBidiStream (
227
- request : MessageStream < EchoMsg > ,
228
- abortSignal ?: AbortSignal ,
229
- ) : MessageStream < EchoMsg > {
232
+ request : MessageStream < EchoMsg > , abortSignal ?: AbortSignal
233
+ ) :
234
+ MessageStream < EchoMsg > {
230
235
const result = this . rpc . bidirectionalStreamingRequest (
231
236
this . service ,
232
237
EchoerDefinition . methods . EchoBidiStream . name ,
@@ -242,9 +247,9 @@ export class EchoerClient implements Echoer {
242
247
* @generated from rpc echo.Echoer.RpcStream
243
248
*/
244
249
RpcStream (
245
- request : MessageStream < RpcStreamPacket > ,
246
- abortSignal ?: AbortSignal ,
247
- ) : MessageStream < RpcStreamPacket > {
250
+ request : MessageStream < RpcStreamPacket > , abortSignal ?: AbortSignal
251
+ ) :
252
+ MessageStream < RpcStreamPacket > {
248
253
const result = this . rpc . bidirectionalStreamingRequest (
249
254
this . service ,
250
255
EchoerDefinition . methods . RpcStream . name ,
@@ -259,7 +264,10 @@ export class EchoerClient implements Echoer {
259
264
*
260
265
* @generated from rpc echo.Echoer.DoNothing
261
266
*/
262
- async DoNothing ( request : Empty , abortSignal ?: AbortSignal ) : Promise < Empty > {
267
+ async DoNothing (
268
+ request : Empty , abortSignal ?: AbortSignal
269
+ ) :
270
+ Promise < Empty > {
263
271
const requestMsg = Empty . create ( request )
264
272
const result = await this . rpc . request (
265
273
this . service ,
@@ -269,4 +277,5 @@ export class EchoerClient implements Echoer {
269
277
)
270
278
return Empty . fromBinary ( result )
271
279
}
280
+
272
281
}
0 commit comments