The Tor Browser / file revision

 var testStr = "This is a test. ";

 for (var i = 0; i < 10; ++i) {

   testStr += testStr;

 }

 function run_test() {

   // Set up our stream to copy

   var inStr = Cc["@mozilla.org/io/string-input-stream;1"]

                 .createInstance(Ci.nsIStringInputStream);

   inStr.setData(testStr, testStr.length);

   // Set up our destination stream.  Make sure to use segments a good

   // bit smaller than our data length.

   do_check_true(testStr.length > 1024*10);

   var pipe = Cc["@mozilla.org/pipe;1"].createInstance(Ci.nsIPipe);

   pipe.init(true, true, 1024, 0xffffffff, null);

   var streamCopier = Cc["@mozilla.org/network/async-stream-copier;1"]

                        .createInstance(Ci.nsIAsyncStreamCopier);

   streamCopier.init(inStr, pipe.outputStream, null, true, true, 1024, true, true);

   var ctx = {

   };

   ctx.wrappedJSObject = ctx;

   var observer = {

     onStartRequest: function(aRequest, aContext) {

       do_check_eq(aContext.wrappedJSObject, ctx);

     },

     onStopRequest: function(aRequest, aContext, aStatusCode) {

       do_check_eq(aStatusCode, 0);

       do_check_eq(aContext.wrappedJSObject, ctx);

       var sis =

         Cc["@mozilla.org/scriptableinputstream;1"]

           .createInstance(Ci.nsIScriptableInputStream);

       sis.init(pipe.inputStream);

       var result = "";

       var temp;

       try { // Need this because read() can throw at EOF

         while ((temp = sis.read(1024))) {

           result += temp;

         }

       } catch(e) {

 	do_check_eq(e.result, Components.results.NS_BASE_STREAM_CLOSED);

       }

       do_check_eq(result, testStr);

       do_test_finished();

     }

   };

   streamCopier.asyncCopy(observer, ctx);

   do_test_pending();  

 }