All Questions
2
questions
1
vote
1
answer
214
views
Proper usage of Monix 3.2.2 Observable with Doobie 0.9.0
I would like to use Monix Observable with Doobie (fs2) stream, but can't seem to get it working properly. Without streaming, my test app exits just fine but after using streaming, my TaskApp seems to ...
- 49
0
votes
0
answers
456
views
Retrying Monix Task - why Task.defer is required here?
I recently spotted a case I can't fully understand while working with Monix Task:
There are two functions (in queue msg handler):
def handle(msg: RollbackMsg): Task[Unit] = {
logger.info(s"...
- 2,099