Moved over to lsio base image

This commit is contained in:
Henry Whitaker
2020-06-10 09:51:51 +01:00
parent ad97579af4
commit e2e9221871
3810 changed files with 154712 additions and 56456 deletions

View File

@@ -2,7 +2,7 @@
var TOKEN = /([!#\$%&'\*\+\-\.\^_`\|~0-9A-Za-z]+)/,
NOTOKEN = /([^!#\$%&'\*\+\-\.\^_`\|~0-9A-Za-z])/g,
QUOTED = /"((?:\\[\x00-\x7f]|[^\x00-\x08\x0a-\x1f\x7f"])*)"/,
QUOTED = /"((?:\\[\x00-\x7f]|[^\x00-\x08\x0a-\x1f\x7f"\\])*)"/,
PARAM = new RegExp(TOKEN.source + '(?:=(?:' + TOKEN.source + '|' + QUOTED.source + '))?'),
EXT = new RegExp(TOKEN.source + '(?: *; *' + PARAM.source + ')*', 'g'),
EXT_LIST = new RegExp('^' + EXT.source + '(?: *, *' + EXT.source + ')*$'),
@@ -83,7 +83,7 @@ Offers.prototype.push = function(name, params) {
this._byName[name] = [];
this._byName[name].push(params);
this._inOrder.push({name: name, params: params});
this._inOrder.push({ name: name, params: params });
};
Offers.prototype.eachOffer = function(callback, context) {

View File

@@ -124,11 +124,11 @@ var crypto = require('crypto'),
large = crypto.randomBytes(1 << 14),
small = new Buffer('hi');
deflate.outgoing({data: large}, function() {
deflate.outgoing({ data: large }, function() {
console.log(1, 'large');
});
deflate.outgoing({data: small}, function() {
deflate.outgoing({ data: small }, function() {
console.log(2, 'small');
});
@@ -205,7 +205,7 @@ order is preserved:
```js
var stream = require('stream'),
session = new stream.Transform({objectMode: true});
session = new stream.Transform({ objectMode: true });
session._transform = function(message, _, callback) {
var self = this;
@@ -276,11 +276,11 @@ above:
```js
var functor = new Functor(deflate, 'outgoing');
functor.call({data: large}, function() {
functor.call({ data: large }, function() {
console.log(1, 'large');
});
functor.call({data: small}, function() {
functor.call({ data: small }, function() {
console.log(2, 'small');
});

View File

@@ -15,7 +15,7 @@ Functor.QUEUE_SIZE = 8;
Functor.prototype.call = function(error, message, callback, context) {
if (this._stopped) return;
var record = {error: error, message: message, callback: callback, context: context, done: false},
var record = { error: error, message: message, callback: callback, context: context, done: false },
called = false,
self = this;

View File

@@ -5,7 +5,7 @@ var Cell = require('./cell'),
var Pipeline = function(sessions) {
this._cells = sessions.map(function(session) { return new Cell(session) });
this._stopped = {incoming: false, outgoing: false};
this._stopped = { incoming: false, outgoing: false };
};
Pipeline.prototype.processIncomingMessage = function(message, callback, context) {
@@ -19,7 +19,7 @@ Pipeline.prototype.processOutgoingMessage = function(message, callback, context)
};
Pipeline.prototype.close = function(callback, context) {
this._stopped = {incoming: true, outgoing: true};
this._stopped = { incoming: true, outgoing: true };
var closed = this._cells.map(function(a) { return a.close() });
if (callback)

View File

@@ -112,7 +112,7 @@ var instance = {
},
validFrameRsv: function(frame) {
var allowed = {rsv1: false, rsv2: false, rsv3: false},
var allowed = { rsv1: false, rsv2: false, rsv3: false },
ext;
if (Extensions.MESSAGE_OPCODES.indexOf(frame.opcode) >= 0) {