1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
///
// Generated code. Do not modify.
// source: kuksa/val/v1/val.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides,camel_case_types,constant_identifier_names,directives_ordering,library_prefixes,non_constant_identifier_names,prefer_final_fields,return_of_invalid_type,unnecessary_const,unnecessary_import,unnecessary_this,unused_import,unused_shown_name
import 'dart:async' as $async;
import 'dart:core' as $core;
import 'package:grpc/service_api.dart' as $grpc;
import 'val.pb.dart' as $0;
export 'val.pb.dart';
class VALClient extends $grpc.Client {
static final _$get = $grpc.ClientMethod<$0.GetRequest, $0.GetResponse>(
'/kuksa.val.v1.VAL/Get',
($0.GetRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $0.GetResponse.fromBuffer(value));
static final _$set = $grpc.ClientMethod<$0.SetRequest, $0.SetResponse>(
'/kuksa.val.v1.VAL/Set',
($0.SetRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $0.SetResponse.fromBuffer(value));
static final _$subscribe =
$grpc.ClientMethod<$0.SubscribeRequest, $0.SubscribeResponse>(
'/kuksa.val.v1.VAL/Subscribe',
($0.SubscribeRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) =>
$0.SubscribeResponse.fromBuffer(value));
static final _$getServerInfo =
$grpc.ClientMethod<$0.GetServerInfoRequest, $0.GetServerInfoResponse>(
'/kuksa.val.v1.VAL/GetServerInfo',
($0.GetServerInfoRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) =>
$0.GetServerInfoResponse.fromBuffer(value));
VALClient($grpc.ClientChannel channel,
{$grpc.CallOptions? options,
$core.Iterable<$grpc.ClientInterceptor>? interceptors})
: super(channel, options: options, interceptors: interceptors);
$grpc.ResponseFuture<$0.GetResponse> get($0.GetRequest request,
{$grpc.CallOptions? options}) {
return $createUnaryCall(_$get, request, options: options);
}
$grpc.ResponseFuture<$0.SetResponse> set($0.SetRequest request,
{$grpc.CallOptions? options}) {
return $createUnaryCall(_$set, request, options: options);
}
$grpc.ResponseStream<$0.SubscribeResponse> subscribe(
$0.SubscribeRequest request,
{$grpc.CallOptions? options}) {
return $createStreamingCall(
_$subscribe, $async.Stream.fromIterable([request]),
options: options);
}
$grpc.ResponseFuture<$0.GetServerInfoResponse> getServerInfo(
$0.GetServerInfoRequest request,
{$grpc.CallOptions? options}) {
return $createUnaryCall(_$getServerInfo, request, options: options);
}
}
abstract class VALServiceBase extends $grpc.Service {
$core.String get $name => 'kuksa.val.v1.VAL';
VALServiceBase() {
$addMethod($grpc.ServiceMethod<$0.GetRequest, $0.GetResponse>(
'Get',
get_Pre,
false,
false,
($core.List<$core.int> value) => $0.GetRequest.fromBuffer(value),
($0.GetResponse value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.SetRequest, $0.SetResponse>(
'Set',
set_Pre,
false,
false,
($core.List<$core.int> value) => $0.SetRequest.fromBuffer(value),
($0.SetResponse value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.SubscribeRequest, $0.SubscribeResponse>(
'Subscribe',
subscribe_Pre,
false,
true,
($core.List<$core.int> value) => $0.SubscribeRequest.fromBuffer(value),
($0.SubscribeResponse value) => value.writeToBuffer()));
$addMethod(
$grpc.ServiceMethod<$0.GetServerInfoRequest, $0.GetServerInfoResponse>(
'GetServerInfo',
getServerInfo_Pre,
false,
false,
($core.List<$core.int> value) =>
$0.GetServerInfoRequest.fromBuffer(value),
($0.GetServerInfoResponse value) => value.writeToBuffer()));
}
$async.Future<$0.GetResponse> get_Pre(
$grpc.ServiceCall call, $async.Future<$0.GetRequest> request) async {
return get(call, await request);
}
$async.Future<$0.SetResponse> set_Pre(
$grpc.ServiceCall call, $async.Future<$0.SetRequest> request) async {
return set(call, await request);
}
$async.Stream<$0.SubscribeResponse> subscribe_Pre($grpc.ServiceCall call,
$async.Future<$0.SubscribeRequest> request) async* {
yield* subscribe(call, await request);
}
$async.Future<$0.GetServerInfoResponse> getServerInfo_Pre(
$grpc.ServiceCall call,
$async.Future<$0.GetServerInfoRequest> request) async {
return getServerInfo(call, await request);
}
$async.Future<$0.GetResponse> get(
$grpc.ServiceCall call, $0.GetRequest request);
$async.Future<$0.SetResponse> set(
$grpc.ServiceCall call, $0.SetRequest request);
$async.Stream<$0.SubscribeResponse> subscribe(
$grpc.ServiceCall call, $0.SubscribeRequest request);
$async.Future<$0.GetServerInfoResponse> getServerInfo(
$grpc.ServiceCall call, $0.GetServerInfoRequest request);
}
|
