io.reactivex.Notification#getError ( )源码实例Demo

下面列出了io.reactivex.Notification#getError ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： retrocache 文件： RecordingObserver.java

public Throwable takeError() {
    Notification<T> notification = takeNotification();
    assertThat(notification.isOnError())
            .as("Expected onError event but was " + notification)
            .isTrue();
    return notification.getError();
}

源代码2 项目： retrocache 文件： RecordingSubscriber.java

public Throwable takeError() {
    Notification<T> notification = takeNotification();
    assertThat(notification.isOnError())
            .as("Expected onError event but was " + notification)
            .isTrue();
    return notification.getError();
}

源代码3 项目： retrocache 文件： RecordingCompletableObserver.java

public Throwable takeError() {
    Notification<?> notification = takeNotification();
    assertThat(notification.isOnError())
            .as("Expected onError event but was " + notification)
            .isTrue();
    return notification.getError();
}

源代码4 项目： retrocache 文件： RecordingSingleObserver.java

public Throwable takeError() {
    Notification<T> notification = takeNotification();
    assertThat(notification.isOnError())
            .as("Expected onError event but was " + notification)
            .isTrue();
    return notification.getError();
}

源代码5 项目： retrocache 文件： RecordingMaybeObserver.java

public Throwable takeError() {
    Notification<T> notification = takeNotification();
    assertThat(notification.isOnError())
            .as("Expected onError event but was " + notification)
            .isTrue();
    return notification.getError();
}

方法所在类

io.reactivex.Notification