|
17 | 17 | import io.reactivex.disposables.Disposable;
|
18 | 18 | import io.reactivex.exceptions.Exceptions;
|
19 | 19 | import io.reactivex.internal.disposables.DisposableHelper;
|
20 |
| -import io.reactivex.internal.functions.ObjectHelper; |
21 | 20 | import io.reactivex.internal.fuseable.QueueDisposable;
|
22 | 21 | import io.reactivex.plugins.RxJavaPlugins;
|
23 | 22 |
|
@@ -91,17 +90,6 @@ protected void afterDownstream() {
|
91 | 90 | // Convenience and state-aware methods
|
92 | 91 | // -----------------------------------
|
93 | 92 |
|
94 |
| - /** |
95 |
| - * Emits the value to the actual subscriber if {@link #done} is false. |
96 |
| - * @param value the value to signal |
97 |
| - */ |
98 |
| - protected final void next(R value) { |
99 |
| - if (done) { |
100 |
| - return; |
101 |
| - } |
102 |
| - actual.onNext(value); |
103 |
| - } |
104 |
| - |
105 | 93 | @Override
|
106 | 94 | public void onError(Throwable t) {
|
107 | 95 | if (done) {
|
@@ -131,16 +119,6 @@ public void onComplete() {
|
131 | 119 | actual.onComplete();
|
132 | 120 | }
|
133 | 121 |
|
134 |
| - /** |
135 |
| - * Checks if the value is null and if so, throws a NullPointerException. |
136 |
| - * @param value the value to check |
137 |
| - * @param message the message to indicate the source of the value |
138 |
| - * @return the value if not null |
139 |
| - */ |
140 |
| - protected final <V> V nullCheck(V value, String message) { |
141 |
| - return ObjectHelper.requireNonNull(value, message); |
142 |
| - } |
143 |
| - |
144 | 122 | /**
|
145 | 123 | * Calls the upstream's QueueDisposable.requestFusion with the mode and
|
146 | 124 | * saves the established mode in {@link #sourceMode}.
|
|
0 commit comments