diff --git a/src/main/java/io/reactivex/processors/AsyncProcessor.java b/src/main/java/io/reactivex/processors/AsyncProcessor.java index 57ad766e5a..b03bef985d 100644 --- a/src/main/java/io/reactivex/processors/AsyncProcessor.java +++ b/src/main/java/io/reactivex/processors/AsyncProcessor.java @@ -138,6 +138,7 @@ public boolean hasComplete() { } @Override + @Nullable public Throwable getThrowable() { return subscribers.get() == TERMINATED ? error : null; } @@ -244,6 +245,7 @@ public boolean hasValue() { *
The method is thread-safe. * @return a single value the Subject currently has or null if no such value exists */ + @Nullable public T getValue() { return subscribers.get() == TERMINATED ? value : null; } diff --git a/src/main/java/io/reactivex/processors/BehaviorProcessor.java b/src/main/java/io/reactivex/processors/BehaviorProcessor.java index bc0d416160..91aa77b942 100644 --- a/src/main/java/io/reactivex/processors/BehaviorProcessor.java +++ b/src/main/java/io/reactivex/processors/BehaviorProcessor.java @@ -348,6 +348,7 @@ public boolean hasSubscribers() { } @Override + @Nullable public Throwable getThrowable() { Object o = value.get(); if (NotificationLite.isError(o)) { @@ -361,6 +362,7 @@ public Throwable getThrowable() { *
The method is thread-safe.
* @return a single value the BehaviorProcessor currently has or null if no such value exists
*/
+ @Nullable
public T getValue() {
Object o = value.get();
if (NotificationLite.isComplete(o) || NotificationLite.isError(o)) {
diff --git a/src/main/java/io/reactivex/processors/PublishProcessor.java b/src/main/java/io/reactivex/processors/PublishProcessor.java
index 92af846040..d299bffea2 100644
--- a/src/main/java/io/reactivex/processors/PublishProcessor.java
+++ b/src/main/java/io/reactivex/processors/PublishProcessor.java
@@ -261,6 +261,7 @@ public boolean hasSubscribers() {
}
@Override
+ @Nullable
public Throwable getThrowable() {
if (subscribers.get() == TERMINATED) {
return error;
diff --git a/src/main/java/io/reactivex/processors/ReplayProcessor.java b/src/main/java/io/reactivex/processors/ReplayProcessor.java
index 069e6628fd..839170fa27 100644
--- a/src/main/java/io/reactivex/processors/ReplayProcessor.java
+++ b/src/main/java/io/reactivex/processors/ReplayProcessor.java
@@ -354,6 +354,7 @@ public boolean hasSubscribers() {
}
@Override
+ @Nullable
public Throwable getThrowable() {
ReplayBuffer