MongoRPCServiceBase constructor

MongoRPCServiceBase()

Implementation

MongoRPCServiceBase() {
  $addMethod($grpc.ServiceMethod<$2.GetDocumentRequest, $0.Value>(
      'GetDocument',
      getDocument_Pre,
      false,
      false,
      ($core.List<$core.int> value) =>
          $2.GetDocumentRequest.fromBuffer(value),
      ($0.Value value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$2.InsertDocumentRequest, $0.ObjectId>(
      'InsertDocument',
      insertDocument_Pre,
      false,
      false,
      ($core.List<$core.int> value) =>
          $2.InsertDocumentRequest.fromBuffer(value),
      ($0.ObjectId value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$2.UpdateDocumentRequest, $0.Value>(
      'UpdateDocument',
      updateDocument_Pre,
      false,
      false,
      ($core.List<$core.int> value) =>
          $2.UpdateDocumentRequest.fromBuffer(value),
      ($0.Value value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$2.DeleteDocumentRequest, $0.Value>(
      'DeleteDocument',
      deleteDocument_Pre,
      false,
      false,
      ($core.List<$core.int> value) =>
          $2.DeleteDocumentRequest.fromBuffer(value),
      ($0.Value value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$2.BulkInsertDocumentsRequest, $0.Value>(
      'BulkInsertDocuments',
      bulkInsertDocuments_Pre,
      false,
      false,
      ($core.List<$core.int> value) =>
          $2.BulkInsertDocumentsRequest.fromBuffer(value),
      ($0.Value value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$2.QueryDocumentsRequest, $0.Value>(
      'QueryDocuments',
      queryDocuments_Pre,
      false,
      false,
      ($core.List<$core.int> value) =>
          $2.QueryDocumentsRequest.fromBuffer(value),
      ($0.Value value) => value.writeToBuffer()));
  $addMethod($grpc.ServiceMethod<$2.ListenRequest, $2.ListenResponse>(
      'Listen',
      listen_Pre,
      false,
      true,
      ($core.List<$core.int> value) => $2.ListenRequest.fromBuffer(value),
      ($2.ListenResponse value) => value.writeToBuffer()));
}