.config/coc/extensions/node_modules/coc-json/node_modules/vscode-jsonrpc/lib/browser/main.js

   1 "use strict";
   2 /* --------------------------------------------------------------------------------------------
   3  * Copyright (c) Microsoft Corporation. All rights reserved.
   4  * Licensed under the MIT License. See License.txt in the project root for license information.
   5  * ------------------------------------------------------------------------------------------ */
   6 var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
   7     if (k2 === undefined) k2 = k;
   8     Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
   9 }) : (function(o, m, k, k2) {
  10     if (k2 === undefined) k2 = k;
  11     o[k2] = m[k];
  12 }));
  13 var __exportStar = (this && this.__exportStar) || function(m, exports) {
  14     for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
  15 };
  16 Object.defineProperty(exports, "__esModule", { value: true });
  17 exports.createMessageConnection = exports.BrowserMessageWriter = exports.BrowserMessageReader = void 0;
  18 const ril_1 = require("./ril");
  19 // Install the browser runtime abstract.
  20 ril_1.default.install();
  21 const api_1 = require("../common/api");
  22 __exportStar(require("../common/api"), exports);
  23 class BrowserMessageReader extends api_1.AbstractMessageReader {
  24     constructor(context) {
  25         super();
  26         this._onData = new api_1.Emitter();
  27         this._messageListener = (event) => {
  28             this._onData.fire(event.data);
  29         };
  30         context.addEventListener('error', (event) => this.fireError(event));
  31         context.onmessage = this._messageListener;
  32     }
  33     listen(callback) {
  34         return this._onData.event(callback);
  35     }
  36 }
  37 exports.BrowserMessageReader = BrowserMessageReader;
  38 class BrowserMessageWriter extends api_1.AbstractMessageWriter {
  39     constructor(context) {
  40         super();
  41         this.context = context;
  42         this.errorCount = 0;
  43         context.addEventListener('error', (event) => this.fireError(event));
  44     }
  45     write(msg) {
  46         try {
  47             this.context.postMessage(msg);
  48             return Promise.resolve();
  49         }
  50         catch (error) {
  51             this.handleError(error, msg);
  52             return Promise.reject(error);
  53         }
  54     }
  55     handleError(error, msg) {
  56         this.errorCount++;
  57         this.fireError(error, msg, this.errorCount);
  58     }
  59     end() {
  60     }
  61 }
  62 exports.BrowserMessageWriter = BrowserMessageWriter;
  63 function createMessageConnection(reader, writer, logger, options) {
  64     if (logger === undefined) {
  65         logger = api_1.NullLogger;
  66     }
  67     if (api_1.ConnectionStrategy.is(options)) {
  68         options = { connectionStrategy: options };
  69     }
  70     return api_1.createMessageConnection(reader, writer, logger, options);
  71 }
  72 exports.createMessageConnection = createMessageConnection;
  73 //# sourceMappingURL=main.js.map