3.x: Update Flowable.throttleLatest MissingBackpressureException message (ReactiveX#7460)

akarnokd · web-flow · commit d53de235975a · 2022-08-09T12:31:29.000+02:00
diff --git a/src/main/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableThrottleLatest.java b/src/main/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableThrottleLatest.java
@@ -306,8 +306,7 @@ void drain() {
         }
 
         void tryDropAndSignalMBE(T valueToDrop) {
-            Throwable errorToSignal = new MissingBackpressureException(
-                    "Could not emit value due to lack of requests");
+            Throwable errorToSignal = MissingBackpressureException.createDefault();
             if (onDropped != null) {
                 try {
                     onDropped.accept(valueToDrop);

Original file line number	Diff line number	Diff line change
`@@ -306,8 +306,7 @@ void drain() {`
`306`	`306`	`}`
`307`	`307`
`308`	`308`	`void tryDropAndSignalMBE(T valueToDrop) {`
`309`		`- Throwable errorToSignal = new MissingBackpressureException(`
`310`		`- "Could not emit value due to lack of requests");`
	`309`	`+ Throwable errorToSignal = MissingBackpressureException.createDefault();`
`311`	`310`	`if (onDropped != null) {`
`312`	`311`	`try {`
`313`	`312`	`onDropped.accept(valueToDrop);`