Как подписаться на Observable, который излучает в какой-то другой части кода? - PullRequest
Новая
       14

Как подписаться на Observable, который излучает в какой-то другой части кода?

1 голос
/ 27 мая 2019

Я новичок в RxJava. У меня есть следующая проблема. У меня есть Presenter и Fragment. Я создаю Presenter внутри onCreate фрагмента. Я хочу подписаться на Observable в конструкторе докладчика. И эта наблюдаемая должна испускаться, когда срабатывает фрагмент onViewCreated (который вызывает некоторый метод в презентаторе, т.е. onViewReady). Проблема, с которой я сталкиваюсь, заключается в том, что когда я создаю Observable (в конструкторе Presenter), мне также необходимо передать эмиттер. Как я могу подписаться на наблюдаемое в конструкторе и потом выбросить внутрь onViewReady?

Я пробовал искать в связке StackOverflow и Medium. Кажется, что все они всегда пропускают излучатель при создании Наблюдаемого.

Фрагмент 

@Override
public void onCreate(@Nullable Bundle savedInstanceState) {
    // create presenter
}

@Override
public void onViewCreated(@NonNull View view, @Nullable Bundle savedInstanceState) {
    // call presenter.onViewReady
}

Presenter 

Presenter() {
    // create and subscribe to observable
}

public void onViewReady() {
    // emit observable
}

Ответы [ 2 ]

0 голосов
/ 28 мая 2019

Вот пример того, как вы могли бы достичь этого: 

private final Observable<MyClass> myObservable;

Presenter() {
    // create observable
    myObservable = Observable.create(new Action1<Emitter<MyClass>>() {
        @Override
        public void call(Emitter<MyClass> emitter) {
            // Emit here
            emitter.onNext(...);
            emitter.onNext(...);

            emitter.onCompleted();
        }
    });
}

public void onViewReady() {
    // subscribe to the observable
    myObservable.subscribeOn(Schedulers.computation())
                .observeOn(AndroidSchedulers::mainThread)
                .subscribe(
                        new Action1<MyClass>() {
                            @Override
                            public void call(MyClass mc) {
                                // TODO implement
                            }
                        },
                        new Action1<Throwable>() {
                            @Override
                            public void call(Throwable throwable) {
                                // TODO implement
                            }
                        }
                );
}
0 голосов
/ 28 мая 2019

Рассматривали ли вы использование предмета?

Код фрагмента: 

public Subject<Integer> subject = PublishSubject.create()

@Override
public void onCreate(@Nullable Bundle savedInstanceState) {
    presenter = new Presenter(subject);
}

@Override
public void onViewCreated(@NonNull View view, @Nullable Bundle savedInstanceState) {
    subject.onNext(1);
}

Код докладчика: 

Presenter(Subject<Integer> subject) {
    subject.doOnNext(i -> onViewReay()).subscribe();
}

public void onViewReady() {
    // code here...
}

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

, и я пробовал это только в RxJava2.поэтому, если вы используете RxJava1, могут потребоваться некоторые дополнительные настройки.

...