Task[_]as a return type
Eithercould have different error types, so you know that you need some transformations to get to the same
Instead of papering over the final type
Task.parMap2. The documentation states that the former is sequential, although the latter is parallel. But it seems, that the implementation of these two are the same except a subtle difference:
Task.map2calls non-static (but final anyway)
Task.zipMapfirst, which, in turn, calls that
Task.mapBoth. So, in my understanding, they both should behave in the same way. What does make one of them sequential and the other one parallel?
Tasks. What's the recommended way to set this up? I'm currently trying to use monix-kafka's
KafkaConsumerObservableand in the process of building out an
Observerwhich I believe means eventually I need convert the
ConsumerRecordinto my data type and kick off my processing within
onNext(). Does that mean I need to run the
consumeWitha better option? And would that mean I need to handle polling?