FM / pipeline

/var/www/qr4y.com/server/delivery/node_modules/websocket-extensions/lib/pipeline/

/var/www/qr4y.com/server/delivery/node_modules/websocket-extensions/lib/pipeline

Name	Size	Mode	Actions
cell.js	1470	0644	edit dl rm
functor.js	1522	0644	edit dl rm
index.js	1480	0644	edit dl rm
pledge.js	779	0644	edit dl rm
README.md	24708	0644	edit dl rm
ring_buffer.js	1671	0644	edit dl rm

Edit: /var/www/qr4y.com/server/delivery/node_modules/websocket-extensions/lib/pipeline/cell.js (1470B)

'use strict';

var Functor = require('./functor'),
    Pledge  = require('./pledge');

var Cell = function(tuple) {
  this._ext     = tuple[0];
  this._session = tuple[1];

this._functors = {
    incoming: new Functor(this._session, 'processIncomingMessage'),
    outgoing: new Functor(this._session, 'processOutgoingMessage')
  };
};

Cell.prototype.pending = function(direction) {
  var functor = this._functors[direction];
  if (!functor._stopped) functor.pending += 1;
};

Cell.prototype.incoming = function(error, message, callback, context) {
  this._exec('incoming', error, message, callback, context);
};

Cell.prototype.outgoing = function(error, message, callback, context) {
  this._exec('outgoing', error, message, callback, context);
};

Cell.prototype.close = function() {
  this._closed = this._closed || new Pledge();
  this._doClose();
  return this._closed;
};

Cell.prototype._exec = function(direction, error, message, callback, context) {
  this._functors[direction].call(error, message, function(err, msg) {
    if (err) err.message = this._ext.name + ': ' + err.message;
    callback.call(context, err, msg);
    this._doClose();
  }, this);
};

Cell.prototype._doClose = function() {
  var fin  = this._functors.incoming,
      fout = this._functors.outgoing;

if (!this._closed || fin.pending + fout.pending !== 0) return;
  if (this._session) this._session.close();
  this._session = null;
  this._closed.done();
};

module.exports = Cell;

cmd: