testing support

[susonthapa]

Coming from Android world, we used to have TestObservers with functions like assertValueCount. But I didn't find any such classes in RxDart (maybe I'm looking at the wrong place).
For testing I have used the test packages that supports stream testing and I have implemented few StreamMatchers. I was just curious if there is any official testing support in the library?

[hoc081098]

You can use Stream.length

final aStream = Stream.fromIterable([1, 2]);
expect(aStream.length, completion(2));