Есть ли какой-либо асинхронный обновленный http-клиент для RxJava?

Question

Reactor-core и Spring 5 только что представили новый async WebClient для своих издателей Mono/Flux.

Поскольку это обычное дело, чтобы обернуть запрос RestTemplate с помощью Observable и subscribeOn, чтобы обеспечить асинхронность, мне было интересно, существует ли какой-либо асинхронный клиент для RxJava.

Я нашел https://github.com/ReactiveX/RxApacheHttp, но он кажется неподдерживаемым, его последняя фиксация - с 2014 года и даже не работает в моих тестах.

Answer 1

Вы можете использовать RxNetty (https://github.com/ReactiveX/RxNetty) основанный на Netty.

Вы также можете использовать ленту Netflix (https://github.com/Netflix/ribbon) вместе с RxNetty.

Answer 2

Да, есть, но не ясно, является ли соответствует вашим потребностям:

Retrofit2

Для того, чтобы позволить, чтобы получить ответы, как Observable добавить следующую строку в ваш build.gradle файл:

compile 'com.squareup.retrofit2:retrofit:2.1.0' 
compile 'com.squareup.retrofit2:converter-gson:2.1.0' 
compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0' 

Среди многих вариантов у вас есть:

Retrofit retrofit = new Retrofit.Builder() 
    (...) 
    .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) 
    (...) 
    .build(); 

После того, что внутри класса, который является интерфейс Retrofit каждая функция может иметь Observable<{class_to_return}> в качестве возвращаемого объекта:

retrofit.create({interface_class}.class) 

класс интерфейса (пример):

Observable<ApiUser> postLogin({parameters});