Kotlin Coroutines – Flow parallel processing

Posted on by David Vassallo

Meant as an alternative to the Kotline Coroutine "Channel", a "Flow" is another way of enabling communication between two co-routines. The difference between the two is essentially that a channel is "hot" (i.e. starts as soon as it is declared), while a flow is "cold" (i.e. only starts when required (or "subscribed to" in reactive … Continue reading Kotlin Coroutines – Flow parallel processing

Python Pickling in the cloud (or how to get python to execute code it hasn’t seen yet)

Posted on by David Vassallo

Problem - What are we trying to solve? Let's assume you have the beginnings of a simple distributed system: You use redis as your event queueYou have a "master" python script that pickles a python class, and sends it to your redis queueYou have a "worker" python script that waits for a new event, unpickles … Continue reading Python Pickling in the cloud (or how to get python to execute code it hasn’t seen yet)