RxBus をシンプルに

README.md

RxBus をちょびっとシンプルに書く

ベースはここ

• OttoからRxJavaへの移行ガイド - Qiita

違うところ

趣味の領域だが、subscribe に以下の処理を入れたり、 filter に o -> o instanceof SomeEvent や map に o -> (SomeEvent) o) を記載するとダサいのでスマートに書く

if (o instanceof SomeEvent) {
  // イベントが来ました
}

RxBus

詳しくは Java ファイルで

書き方

重要なところだけ記載 それ以外は上記のリンク先を参照

RxBusProvider
    .getInstance()
    .toObservable(UpdateHogeEvent.class)
    .map(UpdateHogeEvent::getHoge)
    .subscribe(hoge -> Log.i("Hoge", hoge.toString(), Throwable::printStackTrace);

RxBus.java

package in.tanjo.rxjava.test;

import io.reactivex.Observable;
import io.reactivex.subjects.PublishSubject;

public class RxBus {

  private final PublishSubject<Object> bus = PublishSubject.create();

  public void send(final Object event) {
    bus.onNext(event);
  }

  public Observable<Object> toObservable() {
    return bus.hide();
  }
  
  public <T> Observable<T> toObservable(Class<T> tClass) {
    return bus.cast(tClass).retry();
  }

  public boolean hasObservers() {
    return bus.hasObservers();
  }
}

RxBusProvider.java

package in.tanjo.rxjava.test;

public class RxBusProvider {

  private static final RxBus BUS = new RxBus();

  private RxBusProvider() {
    // No instances.
  }

  public static RxBus getInstance() {
    return BUS;
  }
}