basic-stream.js

const pendingItems = new Rx.Subject();

pendingItems.subscribe((item) => {
  api.syncEvent(item)
  .then((result) => {
    console.log('successfully synced a mouse event');
  })
  .catch((reason) => {
    console.error('got an error while trying to sync an event')
  });
});

function syncMouseEvent(event) {
  pendingItems.next({
    x: event.clientX,
    y: event.clientY
  });
}