Android: function call on RxJava, how?

Question

Android

Hello!
How to implement a function call in RxJava followed by event handling, i.e. timeout or callback?
For example there is:

public Boolean foo(Boolean p){
return !p;
}

Here's how to execute foo() and handle its "behavior"?

Answer 1

Можно так:

Observable.create(
                new Observable.OnSubscribe<T>() {
                    @Override
                    public void call(Subscriber<? super T> sub) {
                        sub.onNext(okhttp запрос);
                        sub.onCompleted();
                    }
                })
                .map(здесь обрабатывем ответ)
                .timeout(5, TimeUnit.SECONDS) //таймаут
                .retry(3) // попытки
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(результат -> выводим, сохраняем);

Answer 2

https://medium.com/yammer-engineering/converting-c...