File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
src/main/java/io/reactivex/rxjava3/internal/operators/observable Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -112,7 +112,7 @@ public void onNext(T t) {
112
112
u = Objects .requireNonNull (iterator .next (), "The iterator returned a null value" );
113
113
} catch (Throwable e ) {
114
114
Exceptions .throwIfFatal (e );
115
- error (e );
115
+ fail (e );
116
116
return ;
117
117
}
118
118
@@ -121,7 +121,7 @@ public void onNext(T t) {
121
121
v = Objects .requireNonNull (zipper .apply (t , u ), "The zipper function returned a null value" );
122
122
} catch (Throwable e ) {
123
123
Exceptions .throwIfFatal (e );
124
- error (e );
124
+ fail (e );
125
125
return ;
126
126
}
127
127
@@ -133,7 +133,7 @@ public void onNext(T t) {
133
133
b = iterator .hasNext ();
134
134
} catch (Throwable e ) {
135
135
Exceptions .throwIfFatal (e );
136
- error (e );
136
+ fail (e );
137
137
return ;
138
138
}
139
139
@@ -144,7 +144,7 @@ public void onNext(T t) {
144
144
}
145
145
}
146
146
147
- void error (Throwable e ) {
147
+ void fail (Throwable e ) {
148
148
done = true ;
149
149
upstream .dispose ();
150
150
downstream .onError (e );
You can’t perform that action at this time.
0 commit comments