docs: function subscribeToStream(streamer, flow){
          var func = function(data){
              setTimeout(() => flow._prePush(data, streamer), 0);
          };
  
          streamer.subscribe(func);
          flow.subscribers[streamer.key] = func;
      }