Back-pressure question

[dahjelle]

I have a situation where I'm parsing a JSON stream, and for each node event, I'd like to fire off an HTTP request and get its response before pushing some data off on to a separate stream. Something like:

oboe(input_stream)
  .node({
    '!.*': function(block, [, counter]) {
      fetch(block.url).then(function(response) {
        output_stream.push(/*whatever*/);
      })
      return oboe.drop;
    }
  })
  .done(function() {
    console.log('Done reading.');
  });

But it seems that this will fire off as many HTTP requests in a row as it can without waiting for the responses, since the .node callback is technically complete right away (and the Promise resolves later).

Is there a way to indicate to oboe when the callback is actually done?

[JuanCaicedo]

Right now, I don't think there is, but this is probably a great feature to add since it has been asked before (#81)