Merge pull request #5 from Sammers21/fix_implementation

remove DummySubscriber
artipie · Feb 18, 2020 · b581a03 · b581a03
2 parents 07faf1a + 7d2cdba
commit b581a03
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 77 deletions.
diff --git a/src/main/java/com/artipie/vertx/DummySubscriber.java b/src/main/java/com/artipie/vertx/DummySubscriber.java
diff --git a/src/main/java/com/artipie/vertx/VertxSliceServer.java b/src/main/java/com/artipie/vertx/VertxSliceServer.java
@@ -135,12 +135,13 @@ private Handler<HttpServerRequest> proxyHandler() {
                     for (final Map.Entry<String, String> header : headers) {
                         response.putHeader(header.getKey(), header.getValue());
                     }
+                    response.setChunked(true);
                     Flowable.fromPublisher(FlowAdapters.toPublisher(body)).map(
                         buf -> {
                             final byte[] bytes = new byte[buf.remaining()];
                             buf.get(bytes);
                             return Buffer.buffer(bytes);
-                        }).subscribe(new DummySubscriber(response));
+                        }).subscribe(response.toSubscriber());
                 }
             );
         };