Buffer byte stream instead of dropping

hawkular · Mar 30, 2018 · 5b385ec · 5b385ec
1 parent 871e94c
commit 5b385ec
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...etrics-api-jaxrs/src/main/java/org/hawkular/metrics/api/servlet/rx/ObservableServlet.java b/...etrics-api-jaxrs/src/main/java/org/hawkular/metrics/api/servlet/rx/ObservableServlet.java
@@ -23,6 +23,7 @@
 import rx.Observable;
 import rx.Observer;
 import rx.Subscriber;
+import rx.exceptions.Exceptions;
 
 /**
  * An {@link Observable} interface to Servlet API
@@ -76,12 +77,12 @@ public static Observable<Void> write(final Observable<byte[]> data, final Servle
         return Observable.create(new Observable.OnSubscribe<Void>() {
             @Override
             public void call(Subscriber<? super Void> subscriber) {
-                Observable<Void> events = create(out).onBackpressureDrop();
+                Observable<Void> events = create(out).onBackpressureBuffer();
                 Observable<Void> writeobs = Observable.zip(data, events, (b, aVoid) -> {
                     try {
                         out.write(b);
                     } catch (IOException ioe) {
-                        ioe.printStackTrace();
+                        Exceptions.propagate(ioe);
                     }
                     return null;
                 });