BufferOverflowException -> MissingBackpressureException

Author: benjchristensen

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

@@ -15,7 +15,6 @@
  */
 package rx.internal.operators;
 
-import java.nio.BufferOverflowException;
 import java.util.Queue;
 import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -24,6 +23,7 @@
 import rx.Observable.Operator;
 import rx.Producer;
 import rx.Subscriber;
+import rx.exceptions.MissingBackpressureException;
 import rx.functions.Action0;
 
 public class OperatorOnBackpressureBuffer<T> implements Operator<T, T> {
@@ -111,7 +111,7 @@ private boolean ensureCapacity() {
                     if (currCapacity <= 0) {
                         if (saturated.compareAndSet(false, true)) {
                             // ensure single completion contract
-                            child.onError(new BufferOverflowException());
+                            child.onError(new MissingBackpressureException("Overflowed buffer of " + OperatorOnBackpressureBuffer.this.capacity));
                             unsubscribe();
                             if (onOverflow != null) {
                                 onOverflow.call();

src/test/java/rx/internal/operators/OperatorOnBackpressureBufferTest.java

@@ -28,6 +28,7 @@
 import rx.Observer;
 import rx.Subscriber;
 import rx.Subscription;
+import rx.exceptions.MissingBackpressureException;
 import rx.functions.Action0;
 import rx.observables.ConnectableObservable;
 import rx.observers.TestSubscriber;
@@ -142,7 +143,7 @@ public void call() {
 
         assertEquals(500, ts.getOnNextEvents().size());
         assertEquals(0, ts.getOnNextEvents().get(0).intValue());
-        assertTrue(ts.getOnErrorEvents().get(0) instanceof BufferOverflowException);
+        assertTrue(ts.getOnErrorEvents().get(0) instanceof MissingBackpressureException);
         assertTrue(s.isUnsubscribed());
 
     }