Use doAfterTerminate

micronaut-projects · Feb 12, 2020 · f3df879 · f3df879
1 parent 1a837c8
commit f3df879
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/http-server-netty/src/main/java/io/micronaut/http/server/netty/RoutingInBoundHandler.java b/http-server-netty/src/main/java/io/micronaut/http/server/netty/RoutingInBoundHandler.java
@@ -1673,7 +1673,7 @@ public HttpContent apply(Object message) {
         });
 
         httpContentPublisher = Flowable.fromPublisher(httpContentPublisher)
-                .doOnTerminate(() -> cleanupRequest(context, request));
+                .doAfterTerminate(() -> cleanupRequest(context, request));
 
         DelegateStreamedHttpResponse streamedResponse = new DelegateStreamedHttpResponse(nativeResponse, httpContentPublisher);
         io.netty.handler.codec.http.HttpHeaders headers = streamedResponse.headers();