FM / tests

/var/www/cobraambalaj/node_modules/events/tests/

/var/www/cobraambalaj/node_modules/events/tests

Name	Size	Mode	Actions
add-listeners.js	3792	0644	edit dl rm
check-listener-leaks.js	3461	0644	edit dl rm
common.js	3204	0644	edit dl rm
errors.js	344	0644	edit dl rm
events-list.js	813	0644	edit dl rm
events-once.js	2454	0644	edit dl rm
index.js	1673	0644	edit dl rm
legacy-compat.js	296	0644	edit dl rm
listener-count.js	1687	0644	edit dl rm
listeners-side-effects.js	2102	0644	edit dl rm
listeners.js	5336	0644	edit dl rm
max-listeners.js	2068	0644	edit dl rm
method-names.js	1665	0644	edit dl rm
modify-in-emit.js	3225	0644	edit dl rm
num-args.js	2217	0644	edit dl rm
once.js	2650	0644	edit dl rm
prepend.js	833	0644	edit dl rm
remove-all-listeners.js	4733	0644	edit dl rm
remove-listeners.js	6597	0644	edit dl rm
set-max-listeners-side-effects.js	1445	0644	edit dl rm
special-event-names.js	1420	0644	edit dl rm
subclass.js	2011	0644	edit dl rm
symbols.js	627	0644	edit dl rm

Edit: /var/www/cobraambalaj/node_modules/events/tests/events-once.js (2454B)

'use strict';

var common = require('./common');
var EventEmitter = require('../').EventEmitter;
var once = require('../').once;
var assert = require('assert');

function onceAnEvent() {
  var ee = new EventEmitter();

process.nextTick(function () {
    ee.emit('myevent', 42);
  });

return once(ee, 'myevent').then(function (args) {
    var value = args[0]
    assert.strictEqual(value, 42);
    assert.strictEqual(ee.listenerCount('error'), 0);
    assert.strictEqual(ee.listenerCount('myevent'), 0);
  });
}

function onceAnEventWithTwoArgs() {
  var ee = new EventEmitter();

process.nextTick(function () {
    ee.emit('myevent', 42, 24);
  });

return once(ee, 'myevent').then(function (value) {
    assert.strictEqual(value.length, 2);
    assert.strictEqual(value[0], 42);
    assert.strictEqual(value[1], 24);
  });
}

function catchesErrors() {
  var ee = new EventEmitter();

var expected = new Error('kaboom');
  var err;
  process.nextTick(function () {
    ee.emit('error', expected);
  });

return once(ee, 'myevent').then(function () {
    throw new Error('should reject')
  }, function (err) {
    assert.strictEqual(err, expected);
    assert.strictEqual(ee.listenerCount('error'), 0);
    assert.strictEqual(ee.listenerCount('myevent'), 0);
  });
}

function stopListeningAfterCatchingError() {
  var ee = new EventEmitter();

var expected = new Error('kaboom');
  var err;
  process.nextTick(function () {
    ee.emit('error', expected);
    ee.emit('myevent', 42, 24);
  });

// process.on('multipleResolves', common.mustNotCall());

return once(ee, 'myevent').then(common.mustNotCall, function (err) {
    // process.removeAllListeners('multipleResolves');
    assert.strictEqual(err, expected);
    assert.strictEqual(ee.listenerCount('error'), 0);
    assert.strictEqual(ee.listenerCount('myevent'), 0);
  });
}

function onceError() {
  var ee = new EventEmitter();

var expected = new Error('kaboom');
  process.nextTick(function () {
    ee.emit('error', expected);
  });

return once(ee, 'error').then(function (args) {
    var err = args[0]
    assert.strictEqual(err, expected);
    assert.strictEqual(ee.listenerCount('error'), 0);
    assert.strictEqual(ee.listenerCount('myevent'), 0);
  });
}

Promise.all([
  onceAnEvent(),
  onceAnEventWithTwoArgs(),
  catchesErrors(),
  stopListeningAfterCatchingError(),
  onceError()
]).catch(function (err) {
  console.error(err.stack)
  process.exit(1)
});

'use strict'; var common = require('./common'); var EventEmitter = require('../').EventEmitter; var once = require('../').once; var assert = require('assert'); function onceAnEvent() { var ee = new EventEmitter(); process.nextTick(function () { ee.emit('myevent', 42); }); return once(ee, 'myevent').then(function (args) { var value = args[0] assert.strictEqual(value, 42); assert.strictEqual(ee.listenerCount('error'), 0); assert.strictEqual(ee.listenerCount('myevent'), 0); }); } function onceAnEventWithTwoArgs() { var ee = new EventEmitter(); process.nextTick(function () { ee.emit('myevent', 42, 24); }); return once(ee, 'myevent').then(function (value) { assert.strictEqual(value.length, 2); assert.strictEqual(value[0], 42); assert.strictEqual(value[1], 24); }); } function catchesErrors() { var ee = new EventEmitter(); var expected = new Error('kaboom'); var err; process.nextTick(function () { ee.emit('error', expected); }); return once(ee, 'myevent').then(function () { throw new Error('should reject') }, function (err) { assert.strictEqual(err, expected); assert.strictEqual(ee.listenerCount('error'), 0); assert.strictEqual(ee.listenerCount('myevent'), 0); }); } function stopListeningAfterCatchingError() { var ee = new EventEmitter(); var expected = new Error('kaboom'); var err; process.nextTick(function () { ee.emit('error', expected); ee.emit('myevent', 42, 24); }); // process.on('multipleResolves', common.mustNotCall()); return once(ee, 'myevent').then(common.mustNotCall, function (err) { // process.removeAllListeners('multipleResolves'); assert.strictEqual(err, expected); assert.strictEqual(ee.listenerCount('error'), 0); assert.strictEqual(ee.listenerCount('myevent'), 0); }); } function onceError() { var ee = new EventEmitter(); var expected = new Error('kaboom'); process.nextTick(function () { ee.emit('error', expected); }); return once(ee, 'error').then(function (args) { var err = args[0] assert.strictEqual(err, expected); assert.strictEqual(ee.listenerCount('error'), 0); assert.strictEqual(ee.listenerCount('myevent'), 0); }); } Promise.all([ onceAnEvent(), onceAnEventWithTwoArgs(), catchesErrors(), stopListeningAfterCatchingError(), onceError() ]).catch(function (err) { console.error(err.stack) process.exit(1) });