Size: a a a

StartAndroid Ru RxJava

2017 July 27

MA

Maxim Antipov in StartAndroid Ru RxJava
А можно простой пример на всяк случай
источник

A

Alexey Turkin in StartAndroid Ru RxJava
Observable<String> myObservable = Observable.create(
   new Observable.OnSubscribe<String😠) {
       @Override
       public void call(Subscriber<? super String> sub) {
           String xml = getXmlFromServer();
           sub.onNext(xml);
           sub.onCompleted();
       }
   }
).subscribeOn(Schedulers.io()).observeOn(AndroidThreads.mainThread());
Subscriber<String> mySubscriber = new Subscriber<String😠) {
   @Override
   public void onNext(String s) { System.out.println(s); }

   @Override
   public void onCompleted() { }

   @Override
   public void onError(Throwable e) { }
};
myObservable.subscribe(mySubscriber);
источник

A

Alexey Turkin in StartAndroid Ru RxJava
думаю, приблизительно, как-то так
источник

A

Alexey Turkin in StartAndroid Ru RxJava
но, естественно, данный код можно оптимизировать, посредством смены типа источника данных, сделать также подписку лямбдой, создание обзервера тоже лямбдой
источник

A

Alexey Turkin in StartAndroid Ru RxJava
но  в целом примерно как-то так будет
источник

A

Alexey Turkin in StartAndroid Ru RxJava
также можно создать fromCallable(), все зависит от твоего метода getXmlFromServer()
источник

A

Alexey Turkin in StartAndroid Ru RxJava
а, если что, писал код не в студии, а прям в чате, так что если будет че подчеркивать, исправь, я просто детально не помню
источник

MA

Maxim Antipov in StartAndroid Ru RxJava
Всё понял, хорошо спасибо
источник

MA

Maxim Antipov in StartAndroid Ru RxJava
Я написал примерно также, просто меня смутило то, что он почти одинаков для всех целей
источник

MA

Maxim Antipov in StartAndroid Ru RxJava
Это как с тестами, когда идут одни и те же ответы
источник

A

Alexey Turkin in StartAndroid Ru RxJava
ну по сути это же одна сторона рх
источник

A

Alexey Turkin in StartAndroid Ru RxJava
рх можно рассматривать настолько с разных сторон, что там вообще жесть начинает твориться
источник

A

Alexey Turkin in StartAndroid Ru RxJava
там же сейчас и RxBus, RxBinding, RxLoader
источник

A

Alexey Turkin in StartAndroid Ru RxJava
лютая жесть
источник

ИК

Илья Кобзев in StartAndroid Ru RxJava
Подскажите какой механизм RxJava применить для реализации отправки запроса в сеть по мере набора в EditText? Понятно, что отправка запроса после ввода каждого символе - не правильно. Нужно определить когда нужно выпонять отправку.
источник

A

Alexey Turkin in StartAndroid Ru RxJava
вообще, в данном случае, насколько я знаю, делают запросы в сеть через интервалы
источник

A

Alexey Turkin in StartAndroid Ru RxJava
то есть, каждые условно говоря, пол секунды
источник

A

Alexey Turkin in StartAndroid Ru RxJava
или секунду
источник

A

Alexey Turkin in StartAndroid Ru RxJava
но там много нюансов касательно ответов от сервера, которые нужно обрабатывать
источник

A

Alexey Turkin in StartAndroid Ru RxJava
необходимо держать пул запросов, то есть, может сложиться ситуация, когда у тебя ответ от 2 запроса пришел раньше, чем от 3, соотвественно, показаны будут некорректные данные польщователю
источник