anchor.diff:        var controller = new StreamController();
         var request = _createMessage(body: controller.stream);
         expect(request.read().toList(),
  -          completion(equals([HELLO_BYTES, WORLD_BYTES])));
  -
  -      controller.add(HELLO_BYTES);
  +          completion(equals([_helloBytes, _worldBytes])));
  +
  +      controller.add(_helloBytes);
         return new Future(() {
           controller
  -          ..add(WORLD_BYTES)
  +          ..add(_worldBytes)
             ..close();
         });
       });
   
       test("supports a List<int> body", () {
  -      var request = _createMessage(body: HELLO_BYTES);
  -      expect(request.read().toList(), completion(equals([HELLO_BYTES])));
  +      var request = _createMessage(body: _helloBytes);
  +      expect(request.read().toList(), completion(equals([_helloBytes])));
       });
   
       test("throws when calling read()/readAsString() multiple times", () {
  
positive.code:       var request = _createMessage(body: controller.stream);
        expect(request.readAsString(), completion(equals("hello, world")));
  
        controller.add(HELLO_BYTES);
        return new Future(() {
          controller
            ..add(WORLD_BYTES)
            ..close();
        });
      });
  
negative.code:     });
  
      test("is null for a stream body", () {
        var request = _createMessage(body: const Stream.empty());
        expect(request.contentLength, isNull);
      });
  
      test("uses the content-length header for a stream body", () {
        var request = _createMessage(
            body: const Stream.empty(), headers: {'content-length': '42'});
        expect(request.contentLength, 42);
        expect(request.isEmpty, isFalse);
      });
  