title: implement queue system with RxJs
body: <p>We have implemented a queue system in Javascript.</p>
  
  <p>Consumers log items and internally it is inserted into a queue (which is an array stored in session storage).</p>
  
  <p>A time interval is used to dequeue a number of items and to send these items to the backend.</p>
  
  <p>How can we implement this using Rxjs and streams?</p>