| OLD | NEW | 
|    1 // Copyright (c) 2012, the Dart project authors.  Please see the AUTHORS file |    1 // Copyright (c) 2012, the Dart project authors.  Please see the AUTHORS file | 
|    2 // for details. All rights reserved. Use of this source code is governed by a |    2 // for details. All rights reserved. Use of this source code is governed by a | 
|    3 // BSD-style license that can be found in the LICENSE file. |    3 // BSD-style license that can be found in the LICENSE file. | 
|    4  |    4  | 
|    5 // VMOptions=--old_gen_heap_size=64 |    5 // VMOptions=--old_gen_heap_size=64 | 
|    6  |    6  | 
|    7 library slow_consumer2_test; |    7 library slow_consumer2_test; | 
|    8  |    8  | 
 |    9 import "package:expect/expect.dart"; | 
|    9 import 'dart:async'; |   10 import 'dart:async'; | 
|   10 import 'dart:isolate'; |   11 import 'dart:isolate'; | 
|   11  |   12  | 
|   12 const int KB = 1024; |   13 const int KB = 1024; | 
|   13 const int MB = KB * KB; |   14 const int MB = KB * KB; | 
|   14 const int GB = KB * KB * KB; |   15 const int GB = KB * KB * KB; | 
|   15  |   16  | 
|   16 class SlowConsumer extends StreamConsumer { |   17 class SlowConsumer extends StreamConsumer { | 
|   17   int receivedCount = 0; |   18   int receivedCount = 0; | 
|   18   final int bytesPerSecond; |   19   final int bytesPerSecond; | 
| (...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  111   // file). If the consumer doesn't pause the data-provider it will run out of |  112   // file). If the consumer doesn't pause the data-provider it will run out of | 
|  112   // heap-space. |  113   // heap-space. | 
|  113  |  114  | 
|  114   new DataProvider(800 * MB, 100 * MB, 1 * MB).stream |  115   new DataProvider(800 * MB, 100 * MB, 1 * MB).stream | 
|  115     .pipe(new SlowConsumer(200 * MB, 5 * MB)) |  116     .pipe(new SlowConsumer(200 * MB, 5 * MB)) | 
|  116     .then((count) { |  117     .then((count) { | 
|  117       port.close(); |  118       port.close(); | 
|  118       Expect.equals(100 * MB, count); |  119       Expect.equals(100 * MB, count); | 
|  119     }); |  120     }); | 
|  120 } |  121 } | 
| OLD | NEW |