rxjava unit test for doOnNext method

In my app I have to execute two API calls in a sequence and after each one I need to update progress in UI.
To do so I have methods apiExecutor.getXObservable() and apiExecutor.getYObservable() where I have doOnNext calls and update UI inside.
My question is to to check with unitTests that my doOnNext logic called.