insomnia/packages/insomnia-app/app/network/grpc/response-callbacks.js

// @flow
import type { ServiceError } from './service-error';
import { GrpcResponseEventEnum } from '../../common/grpc-events';

interface IResponseCallbacks {
  sendData(requestId: string, val: Object | undefined): void;
  sendError(requestId: string, err: ServiceError): void;
}

export class ResponseCallbacks implements IResponseCallbacks {
  _event: IpcMainEvent = null;

  constructor(e: IpcMainEvent) {
    this._event = e;
  }

  sendData(requestId, val) {
    this._event.reply(GrpcResponseEventEnum.data, requestId, val);
  }

  sendError(requestId, err) {
    this._event.reply(GrpcResponseEventEnum.error, requestId, err);
  }
}