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()));
}