Distributed queue over node.js streams