diff options
| -rw-r--r-- | src/broadcast.rs | 5 | ||||
| -rw-r--r-- | src/db/mod.rs | 2 |
2 files changed, 6 insertions, 1 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 diff --git a/src/db/mod.rs b/src/db/mod.rs index e0522d4..632cd9c 100644 --- a/src/db/mod.rs +++ b/src/db/mod.rs @@ -42,7 +42,7 @@ pub async fn prepare(url: &str, backup_url: &str) -> Result<SqlitePool, Error> { Err(Error::Drop(drop_error, migrate_error))?; } else { Err(migrate_error)?; - }; + } } Sqlite::drop_database(backup_url).await?; |
