vladen/aerobus

Pure ES2015, fluent in-memory message bus.

aerobus's Issues

Uncaught TypeError: Cannot read property 'limit' of null

it happens when

channel.subscribe( ... )
.shuffle(2)
.publish();
.shuffle(false) // error is thrown here
.publish();

in this case strategy should be canceled

pending operations do not work as expected

now "pending operations" works like example below:

var bus = aerobus();

var channel1 = bus('test1');
var channel2 = bus('test2');
var channel3 = bus('test3');
var result1 = 0;

channel1.subscribe(
    function() { console.log('when'); }
);

channel3.when('test1', 'test2').publish();

channel1.publish(); // channel3 -> when
channel2.publish(); // channel3 -> when

these operations should work like this:

channel3.when('test1', 'test2').publish();
channel1.publish();
channel2.publish(); // channel3 -> when
channel1.publish();
channel1.publish();
channel1.publish();
channel1.publish();
channel2.publish(); // channel3 -> when
channel2.publish(); // channel3 -> when

Uncaught TypeError: getGear(...).cycle is not a function

This exception occurs when you try to change the strategy in deferred conditional operations

Example:

var bus = aerobus()
  , channel1 = bus('test1')
  , channel2 = bus('test2');

channel2.when('test1').cycle(1); // error is thrown here