We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 26eff79 commit b41ac3bCopy full SHA for b41ac3b
src/main/java/io/reactivex/Emitter.java
@@ -12,6 +12,8 @@
12
*/
13
package io.reactivex;
14
15
+import io.reactivex.annotations.NonNull;
16
+
17
/**
18
* Base interface for emitting signals in a push-fashion in various generator-like source
19
* operators (create, generate).
@@ -24,13 +26,13 @@ public interface Emitter<T> {
24
26
* Signal a normal value.
25
27
* @param value the value to signal, not null
28
- void onNext(T value);
29
+ void onNext(@NonNull T value);
30
31
32
* Signal a Throwable exception.
33
* @param error the Throwable to signal, not null
34
- void onError(Throwable error);
35
+ void onError(@NonNull Throwable error);
36
37
38
* Signal a completion.
0 commit comments