hendrikswan

const pendingItems = new Rx.Subject();
const maxRetries = 3;

const queue = (item) => {
  let workingItem = item;
  
  if (!workingItem.sync) {
    workingItem = {
      sync: { counter: 0 },
      item,

hendrikswan

pendingItems
  .map(item => Rx.Observable.of(item).delay(item.sync.counter > 0 ? delayBetweenRetries : 0))
  .mergeAll()
  .subscribe((itemWithMetaData) => {
  api.syncEvent(itemWithMetaData.item)
  .then((result) => {
    console.log('successfully synced a mouse event');
  })
  .catch((reason) => {
    console.error('got an error while trying to sync an event, going to try again');

hendrikswan

const pendingItems = new Rx.Subject();
const failedItems = new Rx.Subject();
const syncedItems = new Rx.Subject();
const maxRetries = 3;

const queue = (item) => {
  let workingItem = item;
  
  if (!workingItem.sync) {
    workingItem = {

hendrikswan

const sync = createSync({
  maxRetries: 3, 
  delayBetweenRetries: 2000,
  syncAction: api.syncEvent,
});

// success
sync.syncedItems.subscribe(x => console.log(x.item));

// failure 

hendrikswan

const sync = createSync({
  maxRetries: 3, 
  delayBetweenRetries: 2000,
  syncAction: api.syncEvent,
});

// success
sync.syncedItems.subscribe(x => console.log(x.item));

// failure 

hendrikswan

const io = require('socket.io')();

const port = 8000;

io.on('connection', (client) => {
  client.on('subscribeToTimer', (interval) => {
    console.log('client is subscribing to timer with interval ', interval);
    setInterval(() => {
      client.emit('timer', new Date());
    }, interval);

hendrikswan

const io = require('socket.io')();

hendrikswan

io.on('connection', (client) => {
  // here you can start emitting events to the client 
});

hendrikswan

const port = 8000;
io.listen(port);
console.log('listening on port ', port);

hendrikswan

io.on('connection', (client) => {
  client.on('subscribeToTimer', (interval) => {
    console.log('client is subscribing to timer with interval ', interval);
  });
});