Channel refuses content

[flying-sheep]

If i write too much/take too long, i get

NS_BASE_STREAM_WOULD_BLOCK: Component returned failure code: 0x80470007 (NS_BASE_STREAM_WOULD_BLOCK) [nsIOutputStream.write]
undefined 36

[flying-sheep]

initializing the pipe with nonBlockingInput=false, it works.

i just write to it like in the examples, how can i change this to write asynchronously? or is the Pipe not accepting blocking input a bug?

[flying-sheep]

i found a nice workaround here

add to the header:

const {XPCOMUtils} = Cu.import("resource://gre/modules/XPCOMUtils.jsm")
const ThreadManager = Cc['@mozilla.org/thread-manager;1'].
                      getService(Ci.nsIThreadManager);

add to Response.initialize:

this._asyncWait = stream.asyncWait.bind(stream)

and to Response itself:

writeFrom: function(data, end=false) {
  let self = this;
  function writeNextChunk() {
    self._asyncWait({
      QueryInterface: XPCOMUtils.generateQI([Ci.nsIOutputStreamCallback]),
      onOutputStreamReady: function() { try {
        var str = data.next()
        self.write(str, str.length)
        writeNextChunk()
      } catch (e if e instanceof StopIteration) {
        if(end) self.end()
      } }
    }, 0, 0, ThreadManager.currentThread)
  }
  writeNextChunk()
}

then just feed it data:

function myData() {
  yield 'this is so much, it’s blocking!'
}
exports.handler = protocol('much', {
  onRequest: function(request, response) {
    response.writeFrom(myData(), true)
  }
})