Previously we were running dispatcher.unsafeRunsync(io) for every single message we received from pubsub. This is a problem, because the io gets executed on the cats-effect io compute pool. So in order to just receive a message, the app needs to context switch from the subscriber thread to the cats-effect thread and back again. This is very inefficient, especially as we do it for every single event.
The solution is to stop using a Dispatcher inside the subscriber callback.
Previously we were running
dispatcher.unsafeRunsync(io)for every single message we received from pubsub. This is a problem, because theiogets executed on the cats-effect io compute pool. So in order to just receive a message, the app needs to context switch from the subscriber thread to the cats-effect thread and back again. This is very inefficient, especially as we do it for every single event.The solution is to stop using a
Dispatcherinside the subscriber callback.