什麼替換RxJava2

Question

Notification.Kind在RxJava這是可以做到的：

Observable<Notification<Integer>> notifications = Observable 
    .just(3, 0, 2, 0, 1, 0) 
    .concatMapDelayError(x -> fromCallable(() -> 100/x)) 
    .materialize(); 

List<Notification.Kind> kinds = notifications 
    .map(Notification::getKind) 
    .toList() 
    .toBlocking() 
    .single(); 

assertThat(kinds).containsExactly(OnNext, OnNext, OnNext, OnError); 

什麼RxJava2這個替換？

Answer 1

獲得的Observable<Notification<T>>相同RxJava 1.

然而Notification.Kind不再存在。可以定義您自己的enum NotificationKind並根據notification.isOnNext和其他相應的方法映射正確的值。