ベースはここ
趣味の領域だが、subscribe
に以下の処理を入れたり、 filter
に o -> o instanceof SomeEvent
や map
に o -> (SomeEvent) o)
を記載するとダサいのでスマートに書く
if (o instanceof SomeEvent) {
// イベントが来ました
}
詳しくは Java ファイルで
重要なところだけ記載 それ以外は上記のリンク先を参照
RxBusProvider
.getInstance()
.toObservable(UpdateHogeEvent.class)
.map(UpdateHogeEvent::getHoge)
.subscribe(hoge -> Log.i("Hoge", hoge.toString(), Throwable::printStackTrace);