Skip to content

Commit a945b16

Browse files
committed
Adjusted subject error text.
1 parent e5b7f3d commit a945b16

File tree

5 files changed

+5
-5
lines changed

5 files changed

+5
-5
lines changed

src/main/java/rx/internal/operators/OperatorPublish.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ public void onError(Throwable e) {
163163
errors.add(e2);
164164
}
165165
}
166-
Exceptions.throwIfAny(errors, " while propagating an exception.");
166+
Exceptions.throwIfAny(errors, " while emitting onError");
167167
}
168168

169169
@Override

src/main/java/rx/subjects/AsyncSubject.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ public void onError(final Throwable e) {
120120
}
121121
}
122122

123-
Exceptions.throwIfAny(errors, " while propagating an exception.");
123+
Exceptions.throwIfAny(errors, " while emitting AsyncSubject.onError");
124124
}
125125
}
126126

src/main/java/rx/subjects/BehaviorSubject.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,7 @@ public void onError(Throwable e) {
146146
}
147147
}
148148

149-
Exceptions.throwIfAny(errors, " while propagating an exception.");
149+
Exceptions.throwIfAny(errors, " while emitting BehaviorSubject.onError");
150150
}
151151
}
152152

src/main/java/rx/subjects/PublishSubject.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ public void onError(final Throwable e) {
104104
errors.add(e2);
105105
}
106106
}
107-
Exceptions.throwIfAny(errors, " while propagating an exception.");
107+
Exceptions.throwIfAny(errors, " while emitting PublishSubject.onError");
108108
}
109109
}
110110

src/main/java/rx/subjects/ReplaySubject.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -391,7 +391,7 @@ public void onError(final Throwable e) {
391391
}
392392
}
393393

394-
Exceptions.throwIfAny(errors, " while propagating an exception.");
394+
Exceptions.throwIfAny(errors, " while emitting ReplaySubject.onError");
395395
}
396396
}
397397

0 commit comments

Comments
 (0)