generic-synchronous-event-demultiplexer.js

/*pseudocode for event demultplexer*/

socketA, pipeB;
watchedList.add(socketA, FOR_READ);
watchedList.add(pipeB, FOR_READ);

while(events = demultiplexer.watch(watchedList){
  foreach(event in events){
    /*non blocking read always returns data*/
    data = event.resource.read();
    if(data===RESOURCE_CLOSED){
      /*stop watching if resource closed*/
      demultiplexer.unwatch(event.resource);
    }
    else
      consumeData(data);
  }
})