ProcessDataServiceClientPb.ts

/**
 * @fileoverview gRPC-Web generated client stub for AtlasCopco.Enso.Contracts.ProcessData
 * @enhanceable
 * @public
 */

// GENERATED CODE -- DO NOT EDIT!


/* eslint-disable */
// @ts-nocheck


import * as grpcWeb from 'grpc-web';

import * as processData_pb from './processData_pb';


export class GrpcProcessDataServiceClient {
  client_: grpcWeb.AbstractClientBase;
  hostname_: string;
  credentials_: null | { [index: string]: string; };
  options_: null | { [index: string]: any; };

  constructor (hostname: string,
               credentials?: null | { [index: string]: string; },
               options?: null | { [index: string]: any; }) {
    if (!options) options = {};
    if (!credentials) credentials = {};
    options['format'] = 'text';

    this.client_ = new grpcWeb.GrpcWebClientBase(options);
    this.hostname_ = hostname;
    this.credentials_ = credentials;
    this.options_ = options;
  }

  methodInfoWriteProcessVar = new grpcWeb.AbstractClientBase.MethodInfo(
    processData_pb.Result,
    (request: processData_pb.WriteRequest) => {
      return request.serializeBinary();
    },
    processData_pb.Result.deserializeBinary
  );

  writeProcessVar(
    request: processData_pb.WriteRequest,
    metadata: grpcWeb.Metadata | null): Promise<processData_pb.Result>;

  writeProcessVar(
    request: processData_pb.WriteRequest,
    metadata: grpcWeb.Metadata | null,
    callback: (err: grpcWeb.Error,
               response: processData_pb.Result) => void): grpcWeb.ClientReadableStream<processData_pb.Result>;

  writeProcessVar(
    request: processData_pb.WriteRequest,
    metadata: grpcWeb.Metadata | null,
    callback?: (err: grpcWeb.Error,
               response: processData_pb.Result) => void) {
    if (callback !== undefined) {
      return this.client_.rpcCall(
        this.hostname_ +
          '/AtlasCopco.Enso.Contracts.ProcessData.GrpcProcessDataService/WriteProcessVar',
        request,
        metadata || {},
        this.methodInfoWriteProcessVar,
        callback);
    }
    return this.client_.unaryCall(
    this.hostname_ +
      '/AtlasCopco.Enso.Contracts.ProcessData.GrpcProcessDataService/WriteProcessVar',
    request,
    metadata || {},
    this.methodInfoWriteProcessVar);
  }

  methodInfoSubscribeProcessVars = new grpcWeb.AbstractClientBase.MethodInfo(
    processData_pb.ReadResults,
    (request: processData_pb.SubscribeRequest) => {
      return request.serializeBinary();
    },
    processData_pb.ReadResults.deserializeBinary
  );

  subscribeProcessVars(
    request: processData_pb.SubscribeRequest,
    metadata?: grpcWeb.Metadata) {
    return this.client_.serverStreaming(
      this.hostname_ +
        '/AtlasCopco.Enso.Contracts.ProcessData.GrpcProcessDataService/SubscribeProcessVars',
      request,
      metadata || {},
      this.methodInfoSubscribeProcessVars);
  }

}