Rewrite tests that use subscribeAndCount with ObservableStream
#974
| Job | Run time |
|---|---|
| 50s | |
| 50s |
subscribeAndCount with ObservableStream
#974
| Job | Run time |
|---|---|
| 50s | |
| 50s |