https://kotlinlang.org logo
#coroutines
Title
# coroutines
g

groostav

06/17/2019, 9:52 AM
My question is vastly less interesting: I've got a
ReceiveChannel<String>
that I'm looking to conflate on a duration of time, such that I can reduce the number of messages to a known rate. In Tomas Mikula's reactFX this is
successionEnds(duration)
. any idea what the easiest way to get this is?
d

Dico

06/17/2019, 1:39 PM
You could probably make a flow operator
g

groostav

06/18/2019, 12:47 AM
I ended up finding a copy of reactFX on my classpath, so I had an (old) copy of event streams, so I just used that. Pitty there is no combinator for this ready made.
d

Dico

06/18/2019, 1:00 AM
Just a tip, dont start posts saying your question isn't interesting
g

groostav

06/18/2019, 6:49 PM
heh, well when you've got a 45-response thread about some kind of degredation of the default pool used for delay's above yours, its hard to be as interesting, but point taken
3 Views