jamesteague / cyrus Goto Github PK

import cyrus from 'cyrus-rx';

const notifier = cyrus({ appName: 'cyrus-example' });

// It needs to be connected before used
const connectedSuccessfully = await notifier.connect();

if (connectedSuccessfully) {
  // Create an observable to with a channel to listen to
  // Rx.Observable
  const observable$ = notifier.on('example-channel');

  // Sends this to postgres
  // The observable will emit this message.
  notifier.notify('example-channel', 'example-message');
}

// disconnect from the database by ending the pool
notifier.disconnect()