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 index b81fb3df03..e28e5f09df 100644 --- 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);