| OLD | NEW |
| 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, 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 library stream_listen_zeno_test; | 5 library stream_listen_zeno_test; |
| 6 | 6 |
| 7 import "dart:async"; | 7 import "dart:async"; |
| 8 import "package:expect/expect.dart"; | 8 import "package:expect/expect.dart"; |
| 9 import "package:async_helper/async_helper.dart"; | 9 import "package:async_helper/async_helper.dart"; |
| 10 | 10 |
| 11 main() { | 11 main() { |
| 12 asyncStart(); | 12 asyncStart(); |
| 13 var controller; | 13 var controller; |
| 14 for (bool overrideDone in [false, true]) { | 14 for (bool overrideDone in [false, true]) { |
| 15 for (bool sync in [false, true]) { | 15 for (bool sync in [false, true]) { |
| 16 var mode = "${sync ? "-sync" : ""}${overrideDone ? "-od": ""}"; | 16 var mode = "${sync ? "-sync" : ""}${overrideDone ? "-od": ""}"; |
| 17 controller = new StreamController(sync: sync); | 17 controller = new StreamController(sync: sync); |
| 18 testStream("SC$mode", controller, controller.stream, overrideDone); | 18 testStream("SC$mode", controller, controller.stream, overrideDone); |
| 19 controller = new StreamController.broadcast(sync: sync); | 19 controller = new StreamController.broadcast(sync: sync); |
| 20 testStream("BSC$mode", controller, controller.stream, overrideDone); | 20 testStream("BSC$mode", controller, controller.stream, overrideDone); |
| 21 controller = new StreamController(sync: sync); | 21 controller = new StreamController(sync: sync); |
| 22 testStream("SCAB$mode", controller, controller.stream.asBroadcastStream(), | 22 testStream("SCAB$mode", controller, controller.stream.asBroadcastStream(), |
| 23 overrideDone, 3); | 23 overrideDone, 3); |
| 24 controller = new StreamController(sync: sync); | 24 controller = new StreamController(sync: sync); |
| 25 testStream("SCMap$mode", controller, controller.stream.map((x) => x), | 25 testStream("SCMap$mode", controller, controller.stream.map((x) => x), |
| 26 overrideDone, 3); | 26 overrideDone, 3); |
| 27 } | 27 } |
| 28 } | 28 } |
| 29 asyncEnd(); | 29 asyncEnd(); |
| 30 } | 30 } |
| 31 | 31 |
| 32 void testStream(String name, StreamController controller, Stream stream, | 32 void testStream( |
| 33 bool overrideDone, [int registerExpect = 0]) { | 33 String name, StreamController controller, Stream stream, bool overrideDone, |
| 34 [int registerExpect = 0]) { |
| 34 asyncStart(); | 35 asyncStart(); |
| 35 StreamSubscription sub; | 36 StreamSubscription sub; |
| 36 Zone zone; | 37 Zone zone; |
| 37 int registerCount = 0; | 38 int registerCount = 0; |
| 38 int callbackBits = 0; | 39 int callbackBits = 0; |
| 39 int stepCount = 0; | 40 int stepCount = 0; |
| 40 Function step; | 41 Function step; |
| 41 void nextStep() { Zone.ROOT.scheduleMicrotask(step); } | 42 void nextStep() { |
| 43 Zone.ROOT.scheduleMicrotask(step); |
| 44 } |
| 45 |
| 42 runZoned(() { | 46 runZoned(() { |
| 43 zone = Zone.current; | 47 zone = Zone.current; |
| 44 sub = stream.listen((v) { | 48 sub = stream.listen((v) { |
| 45 Expect.identical(zone, Zone.current, name); | 49 Expect.identical(zone, Zone.current, name); |
| 46 Expect.equals(42, v, name); | 50 Expect.equals(42, v, name); |
| 47 callbackBits |= 1; | 51 callbackBits |= 1; |
| 48 nextStep(); | 52 nextStep(); |
| 49 }, onError: (e, s) { | 53 }, onError: (e, s) { |
| 50 Expect.identical(zone, Zone.current, name); | 54 Expect.identical(zone, Zone.current, name); |
| 51 Expect.equals("ERROR", e, name); | 55 Expect.equals("ERROR", e, name); |
| 52 callbackBits |= 2; | 56 callbackBits |= 2; |
| 53 nextStep(); | 57 nextStep(); |
| 54 }, onDone: () { | 58 }, onDone: () { |
| 55 Expect.identical(zone, Zone.current, name); | 59 Expect.identical(zone, Zone.current, name); |
| 56 if (overrideDone) throw "RUNNING WRONG ONDONE"; | 60 if (overrideDone) throw "RUNNING WRONG ONDONE"; |
| 57 callbackBits |= 4; | 61 callbackBits |= 4; |
| 58 nextStep(); | 62 nextStep(); |
| 59 }); | 63 }); |
| 60 registerExpect += 3; | 64 registerExpect += 3; |
| 61 Expect.equals(registerExpect, registerCount, name); | 65 Expect.equals(registerExpect, registerCount, name); |
| 62 }, zoneSpecification: new ZoneSpecification( | 66 }, |
| 63 registerCallback: (self, p, z, callback()) { | 67 zoneSpecification: |
| 64 Expect.identical(zone, self, name); | 68 new ZoneSpecification(registerCallback: (self, p, z, callback()) { |
| 65 registerCount++; | 69 Expect.identical(zone, self, name); |
| 66 return () { | 70 registerCount++; |
| 67 Expect.identical(zone, Zone.current, name); | 71 return () { |
| 68 callback(); | 72 Expect.identical(zone, Zone.current, name); |
| 69 }; | 73 callback(); |
| 70 }, | 74 }; |
| 71 registerUnaryCallback: (self, p, z, callback(a)) { | 75 }, registerUnaryCallback: (self, p, z, callback(a)) { |
| 72 Expect.identical(zone, self, name); | 76 Expect.identical(zone, self, name); |
| 73 registerCount++; | 77 registerCount++; |
| 74 return (a) { | 78 return (a) { |
| 75 Expect.identical(zone, Zone.current, name); | 79 Expect.identical(zone, Zone.current, name); |
| 76 callback(a); | 80 callback(a); |
| 77 }; | 81 }; |
| 78 }, | 82 }, registerBinaryCallback: (self, package, z, callback(a, b)) { |
| 79 registerBinaryCallback: (self, package, z, callback(a, b)) { | 83 Expect.identical(zone, self, name); |
| 80 Expect.identical(zone, self, name); | 84 registerCount++; |
| 81 registerCount++; | 85 return (a, b) { |
| 82 return (a, b) { | 86 Expect.identical(zone, Zone.current, name); |
| 83 Expect.identical(zone, Zone.current, name); | 87 callback(a, b); |
| 84 callback(a, b); | 88 }; |
| 85 }; | 89 })); |
| 86 } | |
| 87 )); | |
| 88 | 90 |
| 89 int expectedBits = 0; | 91 int expectedBits = 0; |
| 90 step = () { | 92 step = () { |
| 91 var stepName = "$name-$stepCount"; | 93 var stepName = "$name-$stepCount"; |
| 92 Expect.identical(Zone.ROOT, Zone.current, stepName); | 94 Expect.identical(Zone.ROOT, Zone.current, stepName); |
| 93 Expect.equals(expectedBits, callbackBits, stepName); | 95 Expect.equals(expectedBits, callbackBits, stepName); |
| 94 switch (stepCount++) { | 96 switch (stepCount++) { |
| 95 case 0: | 97 case 0: |
| 96 expectedBits |= 1; | 98 expectedBits |= 1; |
| 97 controller.add(42); | 99 controller.add(42); |
| (...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 139 } | 141 } |
| 140 Expect.equals(registerExpect, registerCount, stepName); | 142 Expect.equals(registerExpect, registerCount, stepName); |
| 141 controller.close(); | 143 controller.close(); |
| 142 break; | 144 break; |
| 143 case 5: | 145 case 5: |
| 144 asyncEnd(); | 146 asyncEnd(); |
| 145 } | 147 } |
| 146 }; | 148 }; |
| 147 step(); | 149 step(); |
| 148 } | 150 } |
| OLD | NEW |