cxPubSub

cxPubSub

Global Publish / Subscribe messaging bus

Example

const {publish, subscribe} = require('cxPubSub');
async function main(data) {
  subscribe('myEvent', (data) => {
    console.log(data);
  })
  publish('myEvent', {my: 'data'})
  return {a, b};
}

Methods

(static) publish(params, params) → {Promise}

Source:

Publish

Example
publish('myEvent', {my: 'data'});
Parameters:
Name Type Description
params string

Event Name
params object

Payload
Returns:
Type
Promise

(static) subscribe(params, callback) → {Promise}

Source:

Subscribe

Example
subscribe('myEvent', (data) => {
  console.log(data);
});
Parameters:
Name Type Description
params string

Event Name
callback callback

Callback Function
Returns:
Type
Promise