New Rx Hot Shit

rxIsFire.js

let timeExpired = rx.Observable.timer(0, 1000, scheduler)
  .take(timeout + 1)
  .publishLast();
  
let newPlayers = messages.where(e => e.text && e.text.toLowerCase().match(/\byes\b/))
  .map(e => e.user)
  .distinct()
  .take(maxPlayers)
  .publish();

newPlayers.connect();
timeExpired.connect();

// Once our timer has expired, we're done accepting new players.
return newPlayers.takeUntil(timeExpired);