Index: tests/lib/async/stream_event_transform_test.dart |
diff --git a/tests/lib/async/stream_event_transform_test.dart b/tests/lib/async/stream_event_transform_test.dart |
deleted file mode 100644 |
index c10b8f5f073dc5045d17683f8e1d9ffae1b37e39..0000000000000000000000000000000000000000 |
--- a/tests/lib/async/stream_event_transform_test.dart |
+++ /dev/null |
@@ -1,81 +0,0 @@ |
-// Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file |
-// for details. All rights reserved. Use of this source code is governed by a |
-// BSD-style license that can be found in the LICENSE file. |
- |
-library stream_event_transform_test; |
- |
-import "package:expect/expect.dart"; |
-import 'dart:async'; |
-import '../../../pkg/unittest/lib/unittest.dart'; |
-import 'event_helper.dart'; |
- |
-void handleData(int data, EventSink<int> sink) { |
- sink.addError("$data"); |
- sink.add(data + 1); |
-} |
- |
-void handleError(error, EventSink<int> sink) { |
- String value = error; |
- int data = int.parse(value); |
- sink.add(data); |
- sink.addError("${data + 1}"); |
-} |
- |
-void handleDone(EventSink<int> sink) { |
- sink.add(99); |
- sink.close(); |
-} |
- |
-class EventTransformer extends StreamEventTransformer<int,int> { |
- void handleData(int data, EventSink<int> sink) { |
- sink.addError("$data"); |
- sink.add(data + 1); |
- } |
- |
- void handleError(String value, EventSink<int> sink) { |
- int data = int.parse(value); |
- sink.add(data); |
- sink.addError("${data + 1}"); |
- } |
- |
- void handleDone(EventSink<int> sink) { |
- sink.add(99); |
- sink.close(); |
- } |
-} |
- |
-main() { |
- { |
- StreamController c = new StreamController(sync: true); |
- Events expected = new Events()..error("0")..add(1) |
- ..error("1")..add(2) |
- ..add(3)..error("4") |
- ..add(99)..close(); |
- Events input = new Events()..add(0)..add(1)..error("3")..close(); |
- Events actual = new Events.capture( |
- c.stream.transform(new EventTransformer())); |
- actual.onDone(() { |
- Expect.listEquals(expected.events, actual.events); |
- }); |
- input.replay(c); |
- } |
- |
- { |
- StreamController c = new StreamController(sync: true); |
- Events expected = new Events()..error("0")..add(1) |
- ..error("1")..add(2) |
- ..add(3)..error("4") |
- ..add(99)..close(); |
- Events input = new Events()..add(0)..add(1)..error("3")..close(); |
- Events actual = new Events.capture( |
- c.stream.transform(new StreamTransformer( |
- handleData: handleData, |
- handleError: handleError, |
- handleDone: handleDone |
- ))); |
- actual.onDone(() { |
- Expect.listEquals(expected.events, actual.events); |
- }); |
- input.replay(c); |
- } |
-} |