zak.taccardi
01/11/2021, 7:11 PMUnit
every X
milliseconds while it has a subscriber. What’s the idiomatic approach for this?streetsofboston
01/11/2021, 7:13 PMval flow = flow {
while (isActive) {
emit(Unit)
delay(period)
}
}
streetsofboston
01/11/2021, 7:16 PMflow
collector/subscriber (re-)starts the flow.zak.taccardi
01/11/2021, 7:16 PM.shareIn(..)
gildor
01/11/2021, 11:40 PM