DanielZ
09/25/2023, 7:10 AMs4nchez
09/25/2023, 7:13 AMZipkinTracesStorage.THREAD_LOCAL.forCurrentThread()
and ZipkinTracesStorage.THREAD_LOCAL.setForCurrentThread(initialTraces)
DanielZ
09/26/2023, 8:34 AMdave
09/26/2023, 5:56 PMExecutorService.withRequestTracing()
which should make things a lot neater!
We've updated the example and have released this extension function as a part of http4k v5.8.2.0. 🙂DanielZ
09/26/2023, 7:58 PMfredrik.nordin
09/27/2023, 8:01 AMDanielZ
09/27/2023, 8:03 AMNicola
09/29/2023, 12:11 PMs4nchez
09/29/2023, 12:24 PMNicola
09/29/2023, 12:26 PMrequestsChunks.forEach {
apiResponses
.add(CoroutineScope(<http://Dispatchers.IO|Dispatchers.IO>)
.async {
mavService.send(it)
})
}
runBlocking {
apiResponses
.awaitAll()
.flatMap {
it.toList()
}
}
Inside "mavService.send" there is an ok http client which calls an external serviceDanielZ
10/01/2023, 10:04 AMNicola
10/02/2023, 7:04 AMDanielZ
10/02/2023, 7:22 AM