Start from branch master, solution is in branch solution/step1. You can look at the history
of the solution to see changes in the services and implied modifications separately.
- AdminService
- CoinService
- HashrateService
- PoolService
Observable.justObservable.fromObservable.create(try it on PoolService.connect)map
By blocking on the Observable<T>:
- first chain a
toList()if expected result is aList<T> - chain
toBlocking() - collect the result (or throw an
Exception) with various operatorstake(n)single()first()last()???orDefault(T defaultValue)
A cleaner solution (going async all the way) will be presented later.