Skip to content

Instantly share code, notes, and snippets.

@everson
Last active January 30, 2025 20:29
Show Gist options
  • Save everson/7d6456c16e100596cfb26fa74d0c15d8 to your computer and use it in GitHub Desktop.
Save everson/7d6456c16e100596cfb26fa74d0c15d8 to your computer and use it in GitHub Desktop.
Cats IO vs Scalaz Task context shifting.
[ disruptor-http-inbound-1] c.r.d.g.s.e.HttpHandler - HttpHandler.handleHttpRequest
[ disruptor-http-inbound-1] c.r.d.g.s.e.HttpHandler - HttpHandler.handleProcessable
[ disruptor-http-inbound-1] .d.g.t.RequestTransmitter - RequestTransmitter.transmit
[ disruptor-http-inbound-1] c.r.d.g.c.VertxHttpClient - VertxHttpClient.execute
[ io-compute-8] c.r.d.g.c.VertxHttpClient - VertxHttpClient.execute.async
[ io-compute-8] c.r.d.g.c.VertxHttpClient - VertxHttpClient.execute.async.map ip resolved
[vert.x-eventloop-thread-2] c.r.d.g.c.VertxHttpClient - VertxHttpClient.execute.async.map.onSuccess
[ io-compute-9] .d.g.t.RequestTransmitter - RequestTransmitter.transmit.map
[ io-compute-9] uestTransmitterMarshaller - RequestTransmitterMarshaller.marshal
[ io-compute-9] c.r.d.g.s.e.HttpHandler - HttpHandler.handleProcessable.unsafeRunAsync
[ io-compute-9] c.r.d.g.s.e.HttpHandler - HttpHandler.transmitProcessedResponse
[ netty-nio-http-server-3] c.r.d.g.s.e.HttpHandler - HttpHandler.transmitProcessedResponse.operationComplete
def execute(...): IO[Response] = {
logger.info("VertxHttpClient.execute")
val asyncIO = IO.async_[Response] { register =>
logger.info("VertxHttpClient.execute.async")
httpRequest.sendbuffer().onSuccess { response =>
logger.info("VertxHttpClient.execute.async.map.onSuccess")
asyncIO.evalOn(LocalExecutionContext())
[ disruptor-http-inbound-1] c.r.d.g.s.e.HttpHandler - HttpHandler.handleHttpRequest
[ disruptor-http-inbound-1] c.r.d.g.s.e.HttpHandler - HttpHandler.handleProcessable
[ disruptor-http-inbound-1] .d.g.t.RequestTransmitter - RequestTransmitter.transmit
[ disruptor-http-inbound-1] c.r.d.g.c.VertxHttpClient - VertxHttpClient.execute
[ disruptor-http-inbound-1] c.r.d.g.c.VertxHttpClient - VertxHttpClient.execute.async
[ disruptor-http-inbound-1] c.r.d.g.c.VertxHttpClient - VertxHttpClient.execute.async.map ip resolved
[vert.x-eventloop-thread-1] c.r.d.g.c.VertxHttpClient - VertxHttpClient.execute.async.map.onSuccess
[vert.x-eventloop-thread-1] .d.g.t.RequestTransmitter - RequestTransmitter.transmit.map
[vert.x-eventloop-thread-1] uestTransmitterMarshaller - RequestTransmitterMarshaller.marshal
[vert.x-eventloop-thread-1] c.r.d.g.s.e.HttpHandler - HttpHandler.handleProcessable.unsafePerformAsync
[vert.x-eventloop-thread-1] c.r.d.g.s.e.HttpHandler - HttpHandler.transmitProcessedResponse
[ netty-nio-http-server-10] c.r.d.g.s.e.HttpHandler - HttpHandler.transmitProcessedResponse.operationComplete
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment