michael@0: /* Any copyright is dedicated to the Public Domain.
michael@0:  * http://creativecommons.org/publicdomain/zero/1.0/
michael@0:  */
michael@0: 
michael@0: var timer = Components.classes["@mozilla.org/timer;1"];
michael@0: var partTimer = timer.createInstance(Components.interfaces.nsITimer);
michael@0: 
michael@0: function getFileAsInputStream(aFilename) {
michael@0:   var file = Components.classes["@mozilla.org/file/directory_service;1"]
michael@0:              .getService(Components.interfaces.nsIProperties)
michael@0:              .get("CurWorkD", Components.interfaces.nsIFile);
michael@0: 
michael@0:   file.append("tests");
michael@0:   file.append("image");
michael@0:   file.append("test");
michael@0:   file.append("mochitest");
michael@0:   file.append(aFilename);
michael@0: 
michael@0:   var fileStream = Components.classes['@mozilla.org/network/file-input-stream;1']
michael@0:                    .createInstance(Components.interfaces.nsIFileInputStream);
michael@0:   fileStream.init(file, 1, 0, false);
michael@0:   return fileStream;
michael@0: }
michael@0: 
michael@0: function handleRequest(request, response)
michael@0: {
michael@0:   response.setHeader("Content-Type", "image/gif", false);
michael@0:   response.setHeader("Cache-Control", "no-cache", false);
michael@0:   response.setStatusLine(request.httpVersion, 200, "OK");
michael@0:   // We're sending data off in a delayed fashion
michael@0:   response.processAsync();
michael@0:   var inputStream = getFileAsInputStream("animated-gif_trailing-garbage.gif");
michael@0:   var available = inputStream.available(); // = 4029 bytes
michael@0:   // Send the good data at once
michael@0:   response.bodyOutputStream.writeFrom(inputStream, 285);
michael@0:   sendParts(inputStream, response);
michael@0: }
michael@0: 
michael@0: function sendParts(inputStream, response) {
michael@0:   // 3744 left, send in 8 chunks of 468 each
michael@0:   partTimer.initWithCallback(getSendNextPart(inputStream, response), 500,
michael@0:                              Components.interfaces.nsITimer.TYPE_ONE_SHOT);
michael@0: }
michael@0: 
michael@0: function getSendNextPart(inputStream, response) {
michael@0:   return function () {
michael@0:     response.bodyOutputStream.writeFrom(inputStream, 468);
michael@0:     if (!inputStream.available()) {
michael@0:       inputStream.close();
michael@0:       response.finish();
michael@0:     } else {
michael@0:       sendParts(inputStream, response);
michael@0:     }
michael@0:   };
michael@0: }
michael@0: