diff options
Diffstat (limited to 'src/broadcast.rs')
| -rw-r--r-- | src/broadcast.rs | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/broadcast.rs b/src/broadcast.rs index 2792a18..174016e 100644 --- a/src/broadcast.rs +++ b/src/broadcast.rs @@ -51,6 +51,11 @@ where let rx = self.sender().subscribe(); BroadcastStream::from(rx).scan((), |(), r| { + // The following could technically be `r.ok()`, and is exactly + // equivalent to it, but spelling out the match arms means we'll + // find out at compile time if new errors get added to + // `BroadcastStreamRecvError`. + #[allow(clippy::manual_ok_err)] future::ready(match r { Ok(event) => Some(event), // Stop the stream here. This will disconnect SSE clients |