| Index: pkg/shelf/test/message_test.dart
|
| diff --git a/pkg/shelf/test/message_test.dart b/pkg/shelf/test/message_test.dart
|
| index 1db286ba4495ca691c3b5978e38138352cca577b..d393388e8d96589327f40bab7fad6e2469201b26 100644
|
| --- a/pkg/shelf/test/message_test.dart
|
| +++ b/pkg/shelf/test/message_test.dart
|
| @@ -10,10 +10,16 @@ import 'dart:convert';
|
| import 'package:shelf/src/message.dart';
|
| import 'package:unittest/unittest.dart';
|
|
|
| +import 'test_util.dart';
|
| +
|
| class _TestMessage extends Message {
|
| _TestMessage(Map<String, String> headers, Map<String, Object> context,
|
| Stream<List<int>> body)
|
| : super(body, headers: headers, context: context);
|
| +
|
| + Message change({Map<String, String> headers, Map<String, Object> context}) {
|
| + throw new UnimplementedError();
|
| + }
|
| }
|
|
|
| Message _createMessage({Map<String, String> headers,
|
| @@ -76,10 +82,10 @@ void main() {
|
| var request = _createMessage(body: controller.stream);
|
| expect(request.readAsString(), completion(equals("hello, world")));
|
|
|
| - controller.add([104, 101, 108, 108, 111, 44]);
|
| + controller.add(HELLO_BYTES);
|
| return new Future(() {
|
| controller
|
| - ..add([32, 119, 111, 114, 108, 100])
|
| + ..add(WORLD_BYTES)
|
| ..close();
|
| });
|
| });
|
| @@ -114,14 +120,14 @@ void main() {
|
| var controller = new StreamController();
|
| var request = _createMessage(body: controller.stream);
|
| expect(request.read().toList(), completion(equals([
|
| - [104, 101, 108, 108, 111, 44],
|
| - [32, 119, 111, 114, 108, 100]
|
| + HELLO_BYTES,
|
| + WORLD_BYTES
|
| ])));
|
|
|
| - controller.add([104, 101, 108, 108, 111, 44]);
|
| + controller.add(HELLO_BYTES);
|
| return new Future(() {
|
| controller
|
| - ..add([32, 119, 111, 114, 108, 100])
|
| + ..add(WORLD_BYTES)
|
| ..close();
|
| });
|
| });
|
|
|