Close input stream on CloudEventHttpMessageReader (#421)

Signed-off-by: Joke de Buhr <[email protected]>

Author: joke

spring/src/main/java/io/cloudevents/spring/webflux/CloudEventHttpMessageReader.java

@@ -28,6 +28,7 @@
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
+import java.io.InputStream;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
@@ -62,8 +63,8 @@ public Mono<CloudEvent> readMono(ResolvableType elementType, ReactiveHttpInputMe
 			Map<String, Object> hints) {
 		HttpHeaders headers = message.getHeaders();
 		Mono<byte[]> body = DataBufferUtils.join(message.getBody()).map(buffer -> {
-			try {
-				return StreamUtils.copyToByteArray(buffer.asInputStream(true));
+			try (InputStream inputStream = buffer.asInputStream(true)) {
+				return StreamUtils.copyToByteArray(inputStream);
 			}
 			catch (Exception e) {
 				throw new IllegalArgumentException(e);