Is anyone using coroutines and SharedFlow?
Or will we better off sticking with execution managers?
Any tips or examples for a module that needs to await tcp messages and do something™ when there is new data?
I've seen this nice SSE example.
Is anyone using coroutines and SharedFlow?
Or will we better off sticking with execution managers?
Any tips or examples for a module that needs to await tcp messages and do something™ when there is new data?
I've seen this nice SSE example.
If you're in a Kotlin context and know what you're doing, feel free to use coroutines across whatever dispatcher(s) you want. Our first-party OPC UA module uses Kotlin and coroutines heavily.
Even from a Java context, I'd generally recommend folks use standard Executors
over our first-party execution managers.