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.just
Observable.from
Observable.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.