We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9d4631b commit a6c7e33Copy full SHA for a6c7e33
src/main/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableThrottleLatest.java
@@ -306,8 +306,7 @@ void drain() {
306
}
307
308
void tryDropAndSignalMBE(T valueToDrop) {
309
- Throwable errorToSignal = new MissingBackpressureException(
310
- "Could not emit value due to lack of requests");
+ Throwable errorToSignal = MissingBackpressureException.createDefault();
311
if (onDropped != null) {
312
try {
313
onDropped.accept(valueToDrop);
0 commit comments