DataServiceBase constructor

Implementation

DataServiceBase() {
  $addMethod($grpc.ServiceMethod<$0.CreateSubscriptionRequest,
          $0.CreateSubscriptionResponse>(
      'CreateSubscription',
      createSubscription_Pre,
      false,
      false,
      ($core.List<$core.int> value) =>
          $0.CreateSubscriptionRequest.fromBuffer(value),
      ($0.CreateSubscriptionResponse value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$0.DeleteSubscriptionRequest,
          $0.DeleteSubscriptionResponse>(
      'DeleteSubscription',
      deleteSubscription_Pre,
      false,
      false,
      ($core.List<$core.int> value) =>
          $0.DeleteSubscriptionRequest.fromBuffer(value),
      ($0.DeleteSubscriptionResponse value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$0.ListSubscriptionsRequest,
          $0.ListSubscriptionsResponse>(
      'ListSubscriptions',
      listSubscriptions_Pre,
      false,
      false,
      ($core.List<$core.int> value) =>
          $0.ListSubscriptionsRequest.fromBuffer(value),
      ($0.ListSubscriptionsResponse value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$0.FetchRequest, $0.FetchResponse>(
      'Fetch',
      fetch_Pre,
      false,
      false,
      ($core.List<$core.int> value) => $0.FetchRequest.fromBuffer(value),
      ($0.FetchResponse value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$0.StreamRequest, $0.StreamResponse>(
      'Stream',
      stream_Pre,
      false,
      true,
      ($core.List<$core.int> value) => $0.StreamRequest.fromBuffer(value),
      ($0.StreamResponse value) => value.writeToBuffer()));
  $addMethod(
      $grpc.ServiceMethod<$0.AcknowledgeRequest, $0.AcknowledgeResponse>(
          'Acknowledge',
          acknowledge_Pre,
          false,
          false,
          ($core.List<$core.int> value) =>
              $0.AcknowledgeRequest.fromBuffer(value),
          ($0.AcknowledgeResponse value) => value.writeToBuffer()));
}