My question is vastly less interesting: I've got a...
# coroutines
g
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
You could probably make a flow operator
g
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
Just a tip, dont start posts saying your question isn't interesting
g
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