Android: вызов функции на RxJava, как?

Question

[OM1]

Всем привет!
Как реализовать вызов функции в RxJava с последующей обработкой события, т.е. таймаут или коллбек?

К примеру есть:

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

Вот как выполнить foo() и обработать её "поведение"?

Comments

[Денис Загаевский]

Какое у неё поведение? Что нужно сделать и зачем Rx для обычной функции?

[OM1]

Денис Загаевский: имеется ввиду, что эта функция для примера. Мне же надо вызвать okhttp и обработать поведение после вызова

[Денис Загаевский]

OM1: например Observable.fromEmitter

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(результат -> выводим, сохраняем);

Comments

[Денис Загаевский]

create стоит использовать, когда другие способы не подошли.

[Дмитрий Серков]

Денис Загаевский: спасибо, учту.

Answer 2

[Tiberal]

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