RxJava ile ilgili temel bilgileri anlama

Question

Sadece ilk adımlarımı RxJava ile yapıyorum ve bu tutorial numaralı telefonu kullanıyorum. Observable'un ne olduğunu ve Subscriber'un ne olduğunu anlıyorum. Ama onları "bağladığımda" sorunlarım var. Böyle bir görevi düşündüm: Etkinlik A, bir Etkinlik B başlatır. Etkinlik B'de, geçerli tarihi içeren bir Date oluşturabileceğiniz bir düğme bulunur. Başka bir düğme bu Date'u gönderir ve Etkinlik B'yi tamamlar. Etkinlik A yayımlanan Date -Observer'a abone olur ve geçerli tarihi görüntüler. (Bunun normalde Etkinlik sonuçlarını kullanarak yapıldığını biliyorum).

I (mDate tip Date sahiptir ve Etkinlik B'de başka bir yerde oluşturulur örneği) bu kod tarafından Etkinlik B dahilinde bir Date -Observable oluşturabilir:

Observable<Date> dateObservable = 
      Observable.create(sub -> { 
     sub.onNext(mDate); 
     sub.onCompleted(); 
    }); 

Ama ben şu sorun var Etkinlik AI buna abone olmak zorunda. Ama ben ActivityB'de Gözlemlenebilir'e bir atıfta bulunmuyorum. Application sınıfımda Gözlemlenebilir'i statik olarak oluşturmayı düşündüm ama henüz mDate değerini bilmiyorum. Bir şekilde "call()" - Yöntemi (onNext() ve onCompleted()'un çağrıldığı) uygulamadan belirli bir türden Gözlemlenebilir oluşturabilir miyim? O zaman zaten benim Aativity'imde abone olabileceğim Gözlemlenebilir bir örneğim olurdu.Ve daha sonra "call()" - Yöntem B'deki Yöntem'i uygulayabilir miyim? Cevher, tarif ettiğim hedeflere ulaşmak için kullanabileceğim başka RxJava özellikleri var mı?

Answer 1

ReplaySubject adında bir şeye ihtiyacınız vardır. aramaları özel olarak

MyApplication sınıfı:

ReplaySubject<Date> dateSubject = ReplaySubject.create(); 

etkinlik B'de:

ReplaySubject<Date> subject = ((MyApplication)getApplication()).getSubject(); 
subject.onNext(mDate); 
subject.onCompleted(); 

etkinlik A'da:

ReplaySubject<Date> subject = ((MyApplication)getApplication()).getSubject(); 
subject.subscribe(...); 

Bu şey yardımcı olabilecek