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
|
//
// Generated code. Do not modify.
// source: kuksa/val/v1/val.proto
//
// @dart = 2.12
// ignore_for_file: annotate_overrides, camel_case_types, comment_references
// ignore_for_file: constant_identifier_names, library_prefixes
// ignore_for_file: non_constant_identifier_names, prefer_final_fields
// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
import 'dart:async' as $async;
import 'dart:core' as $core;
import 'package:grpc/service_api.dart' as $grpc;
import 'package:protobuf/protobuf.dart' as $pb;
import 'val.pb.dart' as $0;
export 'val.pb.dart';
@$pb.GrpcServiceName('kuksa.val.v1.VAL')
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);
}
}
@$pb.GrpcServiceName('kuksa.val.v1.VAL')
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);
}
|
