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: import 'package:http/src/message.dart';
  
  // "hello,"
  const HELLO_BYTES = const [104, 101, 108, 108, 111, 44];
  
  // " world"
  const WORLD_BYTES = const [32, 119, 111, 114, 108, 100];
  
  class _TestMessage extends Message {
    _TestMessage(Map<String, String> headers, Map<String, Object> context, body,
  
negative.code:       var request = _createMessage(body: controller.stream);
        expect(request.readAsString(), completion(equals("hello, world")));
  
        controller.add(_helloBytes);
        return new Future(() {
          controller
            ..add(_worldBytes)
            ..close();
        });
      });
  