databendlabs / openraft / 19932511981

88%

Build Type

push

github

Committed by drmingdrmer

Commit Message

change: add `subscribe()` method to `WatchSender` trait

Add the ability to create new receivers from a watch channel sender,
mirroring tokio's `watch::Sender::subscribe()` API.

Changes:
- Add `subscribe()` method to `WatchSender` trait
- Implement for tokio, monoio, and compio runtimes
- Add `test_watch_subscribe()` to runtime test suite

Upgrade tip:

If you implement `WatchSender` trait, add the new `subscribe()` method:

```rust
fn subscribe(&self) -> W::Receiver<T> {
    // Return a new receiver connected to this sender
}
```

Run Details

32 of 32 new or added lines in 2 files covered. (100.0%)

3 existing lines in 2 files now uncovered.

14169 of 15284 relevant lines covered (92.7%)

151566.06 hits per line