Polishing

Signed-off-by: Ben Hale <bhale@pivotal.io>

Author: nebhale

cloudfoundry-client-reactor/src/main/java/org/cloudfoundry/reactor/util/Operator.java

@@ -166,7 +166,8 @@ public <T> Mono<T> parseBody(Class<T> bodyType) {
         public <T> Flux<T> parseBodyToFlux(Function<HttpClientResponseWithBody, Publisher<T>> responseTransformer) {
             return this.responseReceiver.responseConnection((response, connection) -> {
                 attachChannelHandlers(response, connection);
-                ByteBufFlux body = connection.inbound().receive();
+                ByteBufFlux body = ByteBufFlux.fromInbound(connection.inbound().receive()
+                    .doFinally(signalType -> connection.dispose()));
 
                 return Mono.just(HttpClientResponseWithBody.of(body, response));
             })