lazzexus/Kafkatorio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

close input stream with .use { }

Browse source
This commit is contained in:
Adam 2022-05-15 13:09:12 +02:00
parent d44d4dbd01
commit 6eb99a841c
1 changed files with 1 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/tileserver/WebMapTileServer.kt
View file

@ -91,8 +91,7 @@ internal class WebMapTileServer(
val requestedETag = request.header("If-None-Match") val requestedETag = request.header("If-None-Match")
var response = next(request) var response = next(request)
val responseBytes = response.body.stream.readAllBytes() val responseBytes = response.body.stream.use { it.readAllBytes() }
response.body.stream.close()
val currentETag = responseBytes.md5() val currentETag = responseBytes.md5()
response = response.body(MemoryBody(responseBytes)) response = response.body(MemoryBody(responseBytes))