| Index: tests/lib_2/async/slow_consumer3_test.dart
|
| diff --git a/tests/lib/async/slow_consumer3_test.dart b/tests/lib_2/async/slow_consumer3_test.dart
|
| similarity index 94%
|
| rename from tests/lib/async/slow_consumer3_test.dart
|
| rename to tests/lib_2/async/slow_consumer3_test.dart
|
| index 96ff202fbdd01870504d7e4f03c89e146d40beac..ae83f204e5414a6880ab9e87361b9b33a062bce8 100644
|
| --- a/tests/lib/async/slow_consumer3_test.dart
|
| +++ b/tests/lib_2/async/slow_consumer3_test.dart
|
| @@ -14,11 +14,11 @@ const int KB = 1024;
|
| const int MB = KB * KB;
|
| const int GB = KB * KB * KB;
|
|
|
| -class SlowConsumer extends StreamConsumer {
|
| +class SlowConsumer extends StreamConsumer<List<int>> {
|
| int receivedCount = 0;
|
| final int bytesPerSecond;
|
| final int bufferSize;
|
| - final List bufferedData = [];
|
| + final List<int> bufferedData = [];
|
| int usedBufferSize = 0;
|
| int finalCount;
|
|
|
| @@ -60,7 +60,7 @@ class SlowConsumer extends StreamConsumer {
|
| }
|
| }
|
|
|
| -Stream<List> dataGenerator(int bytesTotal, int chunkSize) {
|
| +Stream<List<int>> dataGenerator(int bytesTotal, int chunkSize) {
|
| int chunks = bytesTotal ~/ chunkSize;
|
| return new Stream.fromIterable(new Iterable.generate(chunks, (_) {
|
| // This assumes one byte per entry. In practice it will be more.
|
|
|