Returns EndlessSubject representing given topic
const broker = EntityMessageBroker.getInstance(); const subject = broker.emit('test.topic', data);
Get an Observable for specific set of topics
const broker = EntityMessageBroker.getInstance(); broker.on('Candidate.child_added') .subscribe((res) => { // default Observable subscription // handle results });
Topic name / pattern
Rx.Observable for given set of topics
const broker = EntityMessageBroker.getInstance(); const subject = broker.subject('test.topic');
Topic name
Generated using TypeDoc
Returns EndlessSubject representing given topic
const broker = EntityMessageBroker.getInstance(); const subject = broker.emit('test.topic', data);