MessageApiServiceBase constructor
MessageApiServiceBase()
Implementation
MessageApiServiceBase() {
$addMethod($grpc.ServiceMethod<$0.PublishRequest, $0.PublishResponse>(
'Publish',
publish_Pre,
false,
false,
($core.List<$core.int> value) => $0.PublishRequest.fromBuffer(value),
($0.PublishResponse value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.SubscribeRequest, $0.Envelope>(
'Subscribe',
subscribe_Pre,
false,
true,
($core.List<$core.int> value) => $0.SubscribeRequest.fromBuffer(value),
($0.Envelope value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.SubscribeRequest, $0.Envelope>(
'Subscribe2',
subscribe2,
true,
true,
($core.List<$core.int> value) => $0.SubscribeRequest.fromBuffer(value),
($0.Envelope value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.SubscribeAllRequest, $0.Envelope>(
'SubscribeAll',
subscribeAll_Pre,
false,
true,
($core.List<$core.int> value) =>
$0.SubscribeAllRequest.fromBuffer(value),
($0.Envelope value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.QueryRequest, $0.QueryResponse>(
'Query',
query_Pre,
false,
false,
($core.List<$core.int> value) => $0.QueryRequest.fromBuffer(value),
($0.QueryResponse value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.BatchQueryRequest, $0.BatchQueryResponse>(
'BatchQuery',
batchQuery_Pre,
false,
false,
($core.List<$core.int> value) => $0.BatchQueryRequest.fromBuffer(value),
($0.BatchQueryResponse value) => value.writeToBuffer()));
}