#2933. Add tests for Stream.multi constructor.
#2935
Conversation
| stream.listen((v) { | ||
| Expect.equals(v, i++); | ||
| }, onDone: () { | ||
| asyncEnd(); |
There was a problem hiding this comment.
Maybe check here that i is 6. Ditto for j below.
|
|
||
| stream.listen((v) {}, onDone: () { | ||
| stream.listen((v) {}, onDone: () { | ||
| Expect.notEquals(c1, c2); |
There was a problem hiding this comment.
I'd use notIdentical.
They're probably not equal, but we don't actually specify what == does. (That usually means it's the same as identical, but ... sometimes it's not. Like StreamController.broadcast().stream which returns distinct but equal values each time.)
|
|
||
| stream.listen((v) {}, onDone: () { | ||
| asyncEnd(); | ||
| }); |
There was a problem hiding this comment.
(Can be written as onDone: asyncEnd.)
| /// all current listeners, it behaves like a broadcast stream. | ||
| /// | ||
| /// @description Checks that reading of [MultiStreamController.stream] is not | ||
| /// supported. |
There was a problem hiding this comment.
Description not updated for this test?
(Same as for A03_t01.)
| main() { | ||
| asyncStart(); | ||
| var stream = Stream<int>.multi((MultiStreamController<int> controller) { | ||
| print(controller.hasListener); |
There was a problem hiding this comment.
Test true or false? I think it's true. Also not paused, even though you can't send synchronous events before the call to listen has returned.
| controller.close(); | ||
| }, isBroadcast: true); | ||
| Expect.isTrue(stream.isBroadcast); | ||
|
|
There was a problem hiding this comment.
Nothing below here is needed for the test.
|
Are there tests for the |
No description provided.