Rewrite tests that use subscribeAndCount with ObservableStream
#3493
| Job | Run time |
|---|---|
| 1m 20s | |
| 1m 20s |
subscribeAndCount with ObservableStream
#3493
| Job | Run time |
|---|---|
| 1m 20s | |
| 1m 20s |