I'd love to have an equivalent of the tokio::sync::watch types. These provide a channel that stores only the latest value sent. This is convenient for request coalescing: first one in creates the watch and spawns a task to do the request, subsequent requests wait on the existing watch.
I'd love to have an equivalent of the
tokio::sync::watchtypes. These provide a channel that stores only the latest value sent. This is convenient for request coalescing: first one in creates the watch and spawns a task to do the request, subsequent requests wait on the existing watch.