Q:

Using RxJS to implement MessageBus for communication between angularjs modules

Can I create a pub/sub message message queue with RxJS inside angulajs application. I have for example two modules:
ModuleA 
ModuleB
They exists as separate npm package but connected in ModuleC - it's the main shell.
I don't want to create a dependency as ModuleD and create a tight coupling between the modules. So my thought is to create a message bus using RxJS.
Is it possible?
I presume an API will look like that:

RxQueue.subscribe("name:of:the:queuemessage", handler => { handler.result } );
RxQueue.create("name:of:the:queuemessage", (observer) => {
  // implementation of usual Rx subscribtion
})

A:

I think this might be closest to what you are asking for:  
rxmqjs/rxmq.js: JavaScript pub/sub library based on RxJS
https://github.com/rxmqjs/rxmq.js
https://www.npmjs.com/package/rxmq 
Not angular specific, but I consider that a good thing.

