Rewrite tests that use subscribeAndCount with ObservableStream
#2898
| Job | Run time |
|---|---|
| 47s | |
| 47s |
subscribeAndCount with ObservableStream
#2898
| Job | Run time |
|---|---|
| 47s | |
| 47s |