Как обновить пользовательский интерфейс из службы Android с помощью RxJava/RxAndroid

Требуется для RxJava/RxAndroid

1) НАБЛЮДАЕМЫЕ 2) НАБЛЮДАТЕЛИ 3) ПОДПИСАТЬСЯ

Спланируйте, где вам нужно разместить свои 1, 2, 3,

OBSERVABLES идут туда, где создаются данные, поэтому в вашем случае SERVICE

НАБЛЮДАТЕЛИ отправляются туда, где данные должны потребляться (или отображаться), так что это ваша АКТИВНОСТЬ.

ПОДПИСАТЬСЯ можно везде, где у вас есть доступ к ОБСЛУЖИВАЕМЫМ И НАБЛЮДАЮЩИМ, поэтому давайте воспользуемся АКТИВНОСТЬЮ для этого.

Процедура и код:

Во-первых, подготовьте свой OBSERVABLE к обслуживанию, как это

class MyService extends Service {
    static PublishSubject<String> data = PublishSubject.create();

   @Override
   public void onStarCommand(Intent intent,int i, int j){
        # DO THIS ANYWHER WHERE YOU GENERATE DATA 
        data.onNext("Hello");
   }

   public static Observable<String> getObservable(){
      return data;
   }
}

Во-вторых, подготовьте свой OBSERVER (и OBSERVABLE) в Activity onCreate.

Observable<String> observable = MyService.getObservable();
Observer<String> observer = new Observer<String>() {
        @Override
        public void onCompleted() {
            Log.d(TAG, "onCompleted: ");
        }

        @Override
        public void onError(Throwable e) {
            Log.e(TAG, "onError: ",e);
        }

        @Override
        public void onNext(String text) {
            Log.d(TAG, "DATA reveived here: "+text);
        }
    };

Наконец, свяжите OBSERVER и OBSERVABLE в Activity, иначе Observable не ответит, используйте это снова в onCreate.

observable.subscribe(observer);

ГОТОВО, теперь, когда даже данные запускаются из службы с помощью onNext(), данные поступают в действие

Подкласс Binder, который вы используете, когда что-то связывается с вашим Service, может предоставить метод, который возвращает Observable, который выдает данные о ходе выполнения.

Предостережение при таком подходе заключается в том, что у вас есть два ресурса, которые необходимо освободить, когда экземпляр Activity больше недействителен: подключение к службе и наблюдаемая подписка.