Skip to content

Commit afe2b41

Browse files
committed
Add 'request(Long.MAX_VALUE)' in 'onStart' to fix the backpressure issue of debounce
1 parent 34cd1a6 commit afe2b41

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,12 @@ public Subscriber<? super T> call(final Subscriber<? super T> child) {
6262
return new Subscriber<T>(child) {
6363
final DebounceState<T> state = new DebounceState<T>();
6464
final Subscriber<?> self = this;
65+
66+
@Override
67+
public void onStart() {
68+
request(Long.MAX_VALUE);
69+
}
70+
6571
@Override
6672
public void onNext(final T t) {
6773

0 commit comments

Comments
 (0)