vscode-jsonrpc
Advanced tools
Comparing version 9.0.0-next.4 to 9.0.0-next.5
@@ -20,5 +20,8 @@ "use strict"; | ||
}; | ||
var __importDefault = (this && this.__importDefault) || function (mod) { | ||
return (mod && mod.__esModule) ? mod : { "default": mod }; | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.createMessageConnection = exports.BrowserMessageWriter = exports.BrowserMessageReader = void 0; | ||
const ril_1 = require("./ril"); | ||
const ril_1 = __importDefault(require("./ril")); | ||
// Install the browser runtime abstract. | ||
@@ -29,2 +32,4 @@ ril_1.default.install(); | ||
class BrowserMessageReader extends api_1.AbstractMessageReader { | ||
_onData; | ||
_messageListener; | ||
constructor(port) { | ||
@@ -45,2 +50,4 @@ super(); | ||
class BrowserMessageWriter extends api_1.AbstractMessageWriter { | ||
port; | ||
errorCount; | ||
constructor(port) { | ||
@@ -47,0 +54,0 @@ super(); |
@@ -9,2 +9,4 @@ "use strict"; | ||
class MessageBuffer extends api_1.AbstractMessageBuffer { | ||
static emptyBuffer = new Uint8Array(0); | ||
asciiDecoder; | ||
constructor(encoding = 'utf-8') { | ||
@@ -40,4 +42,6 @@ super(encoding); | ||
} | ||
MessageBuffer.emptyBuffer = new Uint8Array(0); | ||
class ReadableStreamWrapper { | ||
socket; | ||
_onData; | ||
_messageListener; | ||
constructor(socket) { | ||
@@ -73,2 +77,3 @@ this.socket = socket; | ||
class WritableStreamWrapper { | ||
socket; | ||
constructor(socket) { | ||
@@ -75,0 +80,0 @@ this.socket = socket; |
@@ -7,2 +7,5 @@ "use strict"; | ||
/// <reference path="../../typings/thenable.d.ts" /> | ||
var __importDefault = (this && this.__importDefault) || function (mod) { | ||
return (mod && mod.__esModule) ? mod : { "default": mod }; | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
@@ -82,3 +85,3 @@ exports.ProgressType = exports.ProgressToken = exports.createMessageConnection = exports.NullLogger = exports.ConnectionOptions = exports.ConnectionStrategy = exports.AbstractMessageBuffer = exports.WriteableStreamMessageWriter = exports.AbstractMessageWriter = exports.MessageWriter = exports.ReadableStreamMessageReader = exports.AbstractMessageReader = exports.MessageReader = exports.SharedArrayReceiverStrategy = exports.SharedArraySenderStrategy = exports.CancellationToken = exports.CancellationTokenSource = exports.Emitter = exports.Event = exports.Disposable = exports.LRUCache = exports.Touch = exports.LinkedMap = exports.ParameterStructures = exports.NotificationType9 = exports.NotificationType8 = exports.NotificationType7 = exports.NotificationType6 = exports.NotificationType5 = exports.NotificationType4 = exports.NotificationType3 = exports.NotificationType2 = exports.NotificationType1 = exports.NotificationType0 = exports.NotificationType = exports.ErrorCodes = exports.ResponseError = exports.RequestType9 = exports.RequestType8 = exports.RequestType7 = exports.RequestType6 = exports.RequestType5 = exports.RequestType4 = exports.RequestType3 = exports.RequestType2 = exports.RequestType1 = exports.RequestType0 = exports.RequestType = exports.Message = exports.RAL = void 0; | ||
Object.defineProperty(exports, "TraceValues", { enumerable: true, get: function () { return connection_1.TraceValues; } }); | ||
const ral_1 = require("./ral"); | ||
const ral_1 = __importDefault(require("./ral")); | ||
exports.RAL = ral_1.default; |
@@ -6,6 +6,32 @@ "use strict"; | ||
*--------------------------------------------------------------------------------------------*/ | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
var desc = Object.getOwnPropertyDescriptor(m, k); | ||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | ||
desc = { enumerable: true, get: function() { return m[k]; } }; | ||
} | ||
Object.defineProperty(o, k2, desc); | ||
}) : (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
o[k2] = m[k]; | ||
})); | ||
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) { | ||
Object.defineProperty(o, "default", { enumerable: true, value: v }); | ||
}) : function(o, v) { | ||
o["default"] = v; | ||
}); | ||
var __importStar = (this && this.__importStar) || function (mod) { | ||
if (mod && mod.__esModule) return mod; | ||
var result = {}; | ||
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k); | ||
__setModuleDefault(result, mod); | ||
return result; | ||
}; | ||
var __importDefault = (this && this.__importDefault) || function (mod) { | ||
return (mod && mod.__esModule) ? mod : { "default": mod }; | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.CancellationTokenSource = exports.CancellationToken = void 0; | ||
const ral_1 = require("./ral"); | ||
const Is = require("./is"); | ||
const ral_1 = __importDefault(require("./ral")); | ||
const Is = __importStar(require("./is")); | ||
const events_1 = require("./events"); | ||
@@ -35,5 +61,4 @@ var CancellationToken; | ||
class MutableToken { | ||
constructor() { | ||
this._isCancelled = false; | ||
} | ||
_isCancelled = false; | ||
_emitter; | ||
cancel() { | ||
@@ -68,2 +93,3 @@ if (!this._isCancelled) { | ||
class CancellationTokenSource { | ||
_token; | ||
get token() { | ||
@@ -70,0 +96,0 @@ if (!this._token) { |
@@ -0,1 +1,2 @@ | ||
/// <reference path="../../typings/thenable.d.ts" /> | ||
import { Message, RequestMessage, RequestType, RequestType0, RequestType1, RequestType2, RequestType3, RequestType4, RequestType5, RequestType6, RequestType7, RequestType8, RequestType9, ResponseMessage, ResponseError, NotificationMessage, NotificationType, NotificationType0, NotificationType1, NotificationType2, NotificationType3, NotificationType4, NotificationType5, NotificationType6, NotificationType7, NotificationType8, NotificationType9, _EM, ParameterStructures } from './messages'; | ||
@@ -2,0 +3,0 @@ import type { Disposable } from './disposable'; |
@@ -6,6 +6,33 @@ "use strict"; | ||
* ------------------------------------------------------------------------------------------ */ | ||
/// <reference path="../../typings/thenable.d.ts" /> | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
var desc = Object.getOwnPropertyDescriptor(m, k); | ||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | ||
desc = { enumerable: true, get: function() { return m[k]; } }; | ||
} | ||
Object.defineProperty(o, k2, desc); | ||
}) : (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
o[k2] = m[k]; | ||
})); | ||
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) { | ||
Object.defineProperty(o, "default", { enumerable: true, value: v }); | ||
}) : function(o, v) { | ||
o["default"] = v; | ||
}); | ||
var __importStar = (this && this.__importStar) || function (mod) { | ||
if (mod && mod.__esModule) return mod; | ||
var result = {}; | ||
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k); | ||
__setModuleDefault(result, mod); | ||
return result; | ||
}; | ||
var __importDefault = (this && this.__importDefault) || function (mod) { | ||
return (mod && mod.__esModule) ? mod : { "default": mod }; | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.createMessageConnection = exports.ConnectionOptions = exports.MessageStrategy = exports.CancellationStrategy = exports.CancellationSenderStrategy = exports.CancellationReceiverStrategy = exports.RequestCancellationReceiverStrategy = exports.IdCancellationReceiverStrategy = exports.ConnectionStrategy = exports.ConnectionError = exports.ConnectionErrors = exports.LogTraceNotification = exports.SetTraceNotification = exports.TraceFormat = exports.TraceValues = exports.TraceValue = exports.Trace = exports.NullLogger = exports.ProgressType = exports.ProgressToken = void 0; | ||
const ral_1 = require("./ral"); | ||
const Is = require("./is"); | ||
const ral_1 = __importDefault(require("./ral")); | ||
const Is = __importStar(require("./is")); | ||
const messages_1 = require("./messages"); | ||
@@ -31,2 +58,8 @@ const linkedMap_1 = require("./linkedMap"); | ||
class ProgressType { | ||
/** | ||
* Clients must not use these properties. They are here to ensure correct typing. | ||
* in TypeScript | ||
*/ | ||
__; | ||
_pr; | ||
constructor() { | ||
@@ -159,2 +192,3 @@ } | ||
class ConnectionError extends Error { | ||
code; | ||
constructor(code, message) { | ||
@@ -161,0 +195,0 @@ super(message); |
@@ -6,5 +6,8 @@ "use strict"; | ||
* ------------------------------------------------------------------------------------------ */ | ||
var __importDefault = (this && this.__importDefault) || function (mod) { | ||
return (mod && mod.__esModule) ? mod : { "default": mod }; | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Emitter = exports.Event = void 0; | ||
const ral_1 = require("./ral"); | ||
const ral_1 = __importDefault(require("./ral")); | ||
var Event; | ||
@@ -16,2 +19,4 @@ (function (Event) { | ||
class CallbackList { | ||
_callbacks; | ||
_contexts; | ||
add(callback, context = null, bucket) { | ||
@@ -75,2 +80,6 @@ if (!this._callbacks) { | ||
class Emitter { | ||
_options; | ||
static _noop = function () { }; | ||
_event; | ||
_callbacks; | ||
constructor(_options) { | ||
@@ -131,2 +140,1 @@ this._options = _options; | ||
exports.Emitter = Emitter; | ||
Emitter._noop = function () { }; |
@@ -6,3 +6,2 @@ "use strict"; | ||
*--------------------------------------------------------------------------------------------*/ | ||
var _a; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
@@ -19,4 +18,9 @@ exports.LRUCache = exports.LinkedMap = exports.Touch = void 0; | ||
class LinkedMap { | ||
[Symbol.toStringTag] = 'LinkedMap'; | ||
_map; | ||
_head; | ||
_tail; | ||
_size; | ||
_state; | ||
constructor() { | ||
this[_a] = 'LinkedMap'; | ||
this._map = new Map(); | ||
@@ -208,3 +212,3 @@ this._head = undefined; | ||
} | ||
[(_a = Symbol.toStringTag, Symbol.iterator)]() { | ||
[Symbol.iterator]() { | ||
return this.entries(); | ||
@@ -373,2 +377,4 @@ } | ||
class LRUCache extends LinkedMap { | ||
_limit; | ||
_ratio; | ||
constructor(limit, ratio = 1) { | ||
@@ -375,0 +381,0 @@ super(); |
@@ -12,2 +12,5 @@ "use strict"; | ||
class AbstractMessageBuffer { | ||
_encoding; | ||
_chunks; | ||
_totalLength; | ||
constructor(encoding = 'utf-8') { | ||
@@ -14,0 +17,0 @@ this._encoding = encoding; |
@@ -6,6 +6,32 @@ "use strict"; | ||
* ------------------------------------------------------------------------------------------ */ | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
var desc = Object.getOwnPropertyDescriptor(m, k); | ||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | ||
desc = { enumerable: true, get: function() { return m[k]; } }; | ||
} | ||
Object.defineProperty(o, k2, desc); | ||
}) : (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
o[k2] = m[k]; | ||
})); | ||
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) { | ||
Object.defineProperty(o, "default", { enumerable: true, value: v }); | ||
}) : function(o, v) { | ||
o["default"] = v; | ||
}); | ||
var __importStar = (this && this.__importStar) || function (mod) { | ||
if (mod && mod.__esModule) return mod; | ||
var result = {}; | ||
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k); | ||
__setModuleDefault(result, mod); | ||
return result; | ||
}; | ||
var __importDefault = (this && this.__importDefault) || function (mod) { | ||
return (mod && mod.__esModule) ? mod : { "default": mod }; | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ReadableStreamMessageReader = exports.AbstractMessageReader = exports.MessageReader = void 0; | ||
const ral_1 = require("./ral"); | ||
const Is = require("./is"); | ||
const ral_1 = __importDefault(require("./ral")); | ||
const Is = __importStar(require("./is")); | ||
const events_1 = require("./events"); | ||
@@ -23,2 +49,5 @@ const semaphore_1 = require("./semaphore"); | ||
class AbstractMessageReader { | ||
errorEmitter; | ||
closeEmitter; | ||
partialMessageEmitter; | ||
constructor() { | ||
@@ -103,2 +132,11 @@ this.errorEmitter = new events_1.Emitter(); | ||
class ReadableStreamMessageReader extends AbstractMessageReader { | ||
readable; | ||
options; | ||
callback; | ||
nextMessageLength; | ||
messageToken; | ||
buffer; | ||
partialMessageTimer; | ||
_partialMessageTimeout; | ||
readSemaphore; | ||
constructor(readable, options) { | ||
@@ -105,0 +143,0 @@ super(); |
@@ -6,5 +6,28 @@ "use strict"; | ||
* ------------------------------------------------------------------------------------------ */ | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
var desc = Object.getOwnPropertyDescriptor(m, k); | ||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | ||
desc = { enumerable: true, get: function() { return m[k]; } }; | ||
} | ||
Object.defineProperty(o, k2, desc); | ||
}) : (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
o[k2] = m[k]; | ||
})); | ||
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) { | ||
Object.defineProperty(o, "default", { enumerable: true, value: v }); | ||
}) : function(o, v) { | ||
o["default"] = v; | ||
}); | ||
var __importStar = (this && this.__importStar) || function (mod) { | ||
if (mod && mod.__esModule) return mod; | ||
var result = {}; | ||
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k); | ||
__setModuleDefault(result, mod); | ||
return result; | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Message = exports.NotificationType9 = exports.NotificationType8 = exports.NotificationType7 = exports.NotificationType6 = exports.NotificationType5 = exports.NotificationType4 = exports.NotificationType3 = exports.NotificationType2 = exports.NotificationType1 = exports.NotificationType0 = exports.NotificationType = exports.RequestType9 = exports.RequestType8 = exports.RequestType7 = exports.RequestType6 = exports.RequestType5 = exports.RequestType4 = exports.RequestType3 = exports.RequestType2 = exports.RequestType1 = exports.RequestType = exports.RequestType0 = exports.AbstractMessageSignature = exports.ParameterStructures = exports.ResponseError = exports.ErrorCodes = void 0; | ||
const is = require("./is"); | ||
const is = __importStar(require("./is")); | ||
/** | ||
@@ -71,2 +94,4 @@ * Predefined error codes. | ||
class ResponseError extends Error { | ||
code; | ||
data; | ||
constructor(code, message, data) { | ||
@@ -91,2 +116,19 @@ super(message); | ||
class ParameterStructures { | ||
kind; | ||
/** | ||
* The parameter structure is automatically inferred on the number of parameters | ||
* and the parameter type in case of a single param. | ||
*/ | ||
static auto = new ParameterStructures('auto'); | ||
/** | ||
* Forces `byPosition` parameter structure. This is useful if you have a single | ||
* parameter which has a literal type. | ||
*/ | ||
static byPosition = new ParameterStructures('byPosition'); | ||
/** | ||
* Forces `byName` parameter structure. This is only useful when having a single | ||
* parameter. The library will report errors if used with a different number of | ||
* parameters. | ||
*/ | ||
static byName = new ParameterStructures('byName'); | ||
constructor(kind) { | ||
@@ -104,21 +146,7 @@ this.kind = kind; | ||
/** | ||
* The parameter structure is automatically inferred on the number of parameters | ||
* and the parameter type in case of a single param. | ||
*/ | ||
ParameterStructures.auto = new ParameterStructures('auto'); | ||
/** | ||
* Forces `byPosition` parameter structure. This is useful if you have a single | ||
* parameter which has a literal type. | ||
*/ | ||
ParameterStructures.byPosition = new ParameterStructures('byPosition'); | ||
/** | ||
* Forces `byName` parameter structure. This is only useful when having a single | ||
* parameter. The library will report errors if used with a different number of | ||
* parameters. | ||
*/ | ||
ParameterStructures.byName = new ParameterStructures('byName'); | ||
/** | ||
* An abstract implementation of a MessageType. | ||
*/ | ||
class AbstractMessageSignature { | ||
method; | ||
numberOfParams; | ||
constructor(method, numberOfParams) { | ||
@@ -137,2 +165,6 @@ this.method = method; | ||
class RequestType0 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -144,2 +176,7 @@ super(method, 0); | ||
class RequestType extends AbstractMessageSignature { | ||
_parameterStructures; | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method, _parameterStructures = ParameterStructures.auto) { | ||
@@ -155,2 +192,7 @@ super(method, 1); | ||
class RequestType1 extends AbstractMessageSignature { | ||
_parameterStructures; | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method, _parameterStructures = ParameterStructures.auto) { | ||
@@ -166,2 +208,6 @@ super(method, 1); | ||
class RequestType2 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -173,2 +219,6 @@ super(method, 2); | ||
class RequestType3 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -180,2 +230,6 @@ super(method, 3); | ||
class RequestType4 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -187,2 +241,6 @@ super(method, 4); | ||
class RequestType5 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -194,2 +252,6 @@ super(method, 5); | ||
class RequestType6 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -201,2 +263,6 @@ super(method, 6); | ||
class RequestType7 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -208,2 +274,6 @@ super(method, 7); | ||
class RequestType8 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -215,2 +285,6 @@ super(method, 8); | ||
class RequestType9 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -222,2 +296,7 @@ super(method, 9); | ||
class NotificationType extends AbstractMessageSignature { | ||
_parameterStructures; | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method, _parameterStructures = ParameterStructures.auto) { | ||
@@ -233,2 +312,6 @@ super(method, 1); | ||
class NotificationType0 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -240,2 +323,7 @@ super(method, 0); | ||
class NotificationType1 extends AbstractMessageSignature { | ||
_parameterStructures; | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method, _parameterStructures = ParameterStructures.auto) { | ||
@@ -251,2 +339,6 @@ super(method, 1); | ||
class NotificationType2 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -258,2 +350,6 @@ super(method, 2); | ||
class NotificationType3 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -265,2 +361,6 @@ super(method, 3); | ||
class NotificationType4 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -272,2 +372,6 @@ super(method, 4); | ||
class NotificationType5 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -279,2 +383,6 @@ super(method, 5); | ||
class NotificationType6 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -286,2 +394,6 @@ super(method, 6); | ||
class NotificationType7 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -293,2 +405,6 @@ super(method, 7); | ||
class NotificationType8 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -300,2 +416,6 @@ super(method, 8); | ||
class NotificationType9 extends AbstractMessageSignature { | ||
/** | ||
* Clients must not use this property. It is here to ensure correct typing. | ||
*/ | ||
_; | ||
constructor(method) { | ||
@@ -302,0 +422,0 @@ super(method, 9); |
@@ -6,6 +6,32 @@ "use strict"; | ||
* ------------------------------------------------------------------------------------------ */ | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
var desc = Object.getOwnPropertyDescriptor(m, k); | ||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | ||
desc = { enumerable: true, get: function() { return m[k]; } }; | ||
} | ||
Object.defineProperty(o, k2, desc); | ||
}) : (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
o[k2] = m[k]; | ||
})); | ||
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) { | ||
Object.defineProperty(o, "default", { enumerable: true, value: v }); | ||
}) : function(o, v) { | ||
o["default"] = v; | ||
}); | ||
var __importStar = (this && this.__importStar) || function (mod) { | ||
if (mod && mod.__esModule) return mod; | ||
var result = {}; | ||
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k); | ||
__setModuleDefault(result, mod); | ||
return result; | ||
}; | ||
var __importDefault = (this && this.__importDefault) || function (mod) { | ||
return (mod && mod.__esModule) ? mod : { "default": mod }; | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.WriteableStreamMessageWriter = exports.AbstractMessageWriter = exports.MessageWriter = void 0; | ||
const ral_1 = require("./ral"); | ||
const Is = require("./is"); | ||
const ral_1 = __importDefault(require("./ral")); | ||
const Is = __importStar(require("./is")); | ||
const semaphore_1 = require("./semaphore"); | ||
@@ -25,2 +51,4 @@ const events_1 = require("./events"); | ||
class AbstractMessageWriter { | ||
errorEmitter; | ||
closeEmitter; | ||
constructor() { | ||
@@ -69,2 +97,6 @@ this.errorEmitter = new events_1.Emitter(); | ||
class WriteableStreamMessageWriter extends AbstractMessageWriter { | ||
writable; | ||
options; | ||
errorCount; | ||
writeSemaphore; | ||
constructor(writable, options) { | ||
@@ -71,0 +103,0 @@ super(); |
@@ -6,6 +6,12 @@ "use strict"; | ||
* ------------------------------------------------------------------------------------------ */ | ||
var __importDefault = (this && this.__importDefault) || function (mod) { | ||
return (mod && mod.__esModule) ? mod : { "default": mod }; | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Semaphore = void 0; | ||
const ral_1 = require("./ral"); | ||
const ral_1 = __importDefault(require("./ral")); | ||
class Semaphore { | ||
_capacity; | ||
_active; | ||
_waiting; | ||
constructor(capacity = 1) { | ||
@@ -12,0 +18,0 @@ if (capacity <= 0) { |
@@ -15,2 +15,3 @@ "use strict"; | ||
class SharedArraySenderStrategy { | ||
buffers; | ||
constructor() { | ||
@@ -46,2 +47,3 @@ this.buffers = new Map(); | ||
class SharedArrayBufferCancellationToken { | ||
data; | ||
constructor(buffer) { | ||
@@ -58,2 +60,3 @@ this.data = new Int32Array(buffer, 0, 1); | ||
class SharedArrayBufferCancellationTokenSource { | ||
token; | ||
constructor(buffer) { | ||
@@ -68,5 +71,3 @@ this.token = new SharedArrayBufferCancellationToken(buffer); | ||
class SharedArrayReceiverStrategy { | ||
constructor() { | ||
this.kind = 'request'; | ||
} | ||
kind = 'request'; | ||
createCancellationTokenSource(request) { | ||
@@ -73,0 +74,0 @@ const buffer = request.$cancellationData; |
@@ -13,5 +13,20 @@ "use strict"; | ||
})); | ||
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) { | ||
Object.defineProperty(o, "default", { enumerable: true, value: v }); | ||
}) : function(o, v) { | ||
o["default"] = v; | ||
}); | ||
var __importStar = (this && this.__importStar) || function (mod) { | ||
if (mod && mod.__esModule) return mod; | ||
var result = {}; | ||
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k); | ||
__setModuleDefault(result, mod); | ||
return result; | ||
}; | ||
var __exportStar = (this && this.__exportStar) || function(m, exports) { | ||
for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p); | ||
}; | ||
var __importDefault = (this && this.__importDefault) || function (mod) { | ||
return (mod && mod.__esModule) ? mod : { "default": mod }; | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
@@ -23,8 +38,8 @@ exports.createMessageConnection = exports.createServerSocketTransport = exports.createClientSocketTransport = exports.createServerPipeTransport = exports.createClientPipeTransport = exports.generateRandomPipeName = exports.StreamMessageWriter = exports.StreamMessageReader = exports.SocketMessageWriter = exports.SocketMessageReader = exports.PortMessageWriter = exports.PortMessageReader = exports.IPCMessageWriter = exports.IPCMessageReader = void 0; | ||
* ----------------------------------------------------------------------------------------- */ | ||
const ril_1 = require("./ril"); | ||
const ril_1 = __importDefault(require("./ril")); | ||
// Install the node runtime abstract. | ||
ril_1.default.install(); | ||
const path = require("path"); | ||
const os = require("os"); | ||
const fs = require("fs"); | ||
const path = __importStar(require("path")); | ||
const os = __importStar(require("os")); | ||
const fs = __importStar(require("fs")); | ||
const crypto_1 = require("crypto"); | ||
@@ -35,2 +50,3 @@ const net_1 = require("net"); | ||
class IPCMessageReader extends api_1.AbstractMessageReader { | ||
process; | ||
constructor(process) { | ||
@@ -50,2 +66,4 @@ super(); | ||
class IPCMessageWriter extends api_1.AbstractMessageWriter { | ||
process; | ||
errorCount; | ||
constructor(process) { | ||
@@ -88,2 +106,3 @@ super(); | ||
class PortMessageReader extends api_1.AbstractMessageReader { | ||
onData; | ||
constructor(port) { | ||
@@ -104,2 +123,4 @@ super(); | ||
class PortMessageWriter extends api_1.AbstractMessageWriter { | ||
port; | ||
errorCount; | ||
constructor(port) { | ||
@@ -137,2 +158,3 @@ super(); | ||
class SocketMessageWriter extends api_1.WriteableStreamMessageWriter { | ||
socket; | ||
constructor(socket, options) { | ||
@@ -139,0 +161,0 @@ super((0, ril_1.default)().stream.asWritableStream(socket), options); |
@@ -10,2 +10,3 @@ "use strict"; | ||
class MessageBuffer extends api_1.AbstractMessageBuffer { | ||
static emptyBuffer = Buffer.allocUnsafe(0); | ||
constructor(encoding = 'utf-8') { | ||
@@ -40,4 +41,4 @@ super(encoding); | ||
} | ||
MessageBuffer.emptyBuffer = Buffer.allocUnsafe(0); | ||
class ReadableStreamWrapper { | ||
stream; | ||
constructor(stream) { | ||
@@ -64,2 +65,3 @@ this.stream = stream; | ||
class WritableStreamWrapper { | ||
stream; | ||
constructor(stream) { | ||
@@ -66,0 +68,0 @@ this.stream = stream; |
{ | ||
"name": "vscode-jsonrpc", | ||
"description": "A json rpc implementation over streams", | ||
"version": "9.0.0-next.4", | ||
"version": "9.0.0-next.5", | ||
"author": "Microsoft Corporation", | ||
@@ -18,7 +18,16 @@ "license": "MIT", | ||
}, | ||
"main": "./lib/node/main.js", | ||
"browser": { | ||
"./lib/node/main.js": "./lib/browser/main.js" | ||
"exports": { | ||
".": { | ||
"types": "./lib/common/api.d.ts", | ||
"default": "./lib/common/api.js" | ||
}, | ||
"./node": { | ||
"types": "./lib/node/main.d.ts", | ||
"node": "./lib/node/main.js" | ||
}, | ||
"./browser": { | ||
"types": "./lib/browser/main.d.ts", | ||
"browser": "./lib/browser/main.js" | ||
} | ||
}, | ||
"typings": "./lib/common/api.d.ts", | ||
"devDependencies": { | ||
@@ -32,6 +41,6 @@ "@types/msgpack-lite": "^0.1.10", | ||
"preversion": "npm test", | ||
"compile": "node ../build/bin/tsc -b ./tsconfig.json", | ||
"watch": "node ../build/bin/tsc -b ./tsconfig.watch.json -w", | ||
"clean": "node ../node_modules/rimraf/dist/esm/bin.mjs lib && node ../node_modules/rimraf/dist/esm/bin.mjs dist", | ||
"lint": "node ../node_modules/eslint/bin/eslint.js --ext ts src", | ||
"compile": "tsc -b ./tsconfig.json", | ||
"watch": "tsc -b ./tsconfig.watch.json -w", | ||
"clean": "rimraf lib && rimraf dist", | ||
"lint": "eslint --ext ts src", | ||
"test": "npm run test:node && npm run test:browser", | ||
@@ -44,5 +53,5 @@ "test:node": "node ../node_modules/mocha/bin/_mocha", | ||
"all": "npm run clean && npm run compile && npm run lint && npm run test", | ||
"compile:publish": "node ../build/bin/tsc -b ./tsconfig.publish.json", | ||
"compile:publish": "tsc -b ./tsconfig.publish.json", | ||
"all:publish": "git clean -xfd . && npm install && npm run compile:publish && npm run lint && npm run test" | ||
} | ||
} |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
218411
5284
44