什么替换了 RxJava2 中的 Notification.Kind

Question

在 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 和其他相应方法映射正确的值。

什么替换了 RxJava2 中的 Notification.Kind

What replaces Notification.Kind in RxJava2

java

rx-java2