elizarov
10/11/2017, 12:33 PMConflatedChannel
and offer
elements to it (it will always succeed). If you need to track all updates (cannot afford to miss intermediate values), then you can either use a channel with unlimited capacity (LinkedListChannel
) and similarly offert
elements to it or use a limited-capacity channel (either RendezvousChannel
or ArrayChannel
) and use runBlocking { c.send(x) }
to make sure all updates are delivered.