Index: Cargo.toml ================================================================== --- Cargo.toml +++ Cargo.toml @@ -1,8 +1,8 @@ [package] name = "limqch" -version = "0.2.1" +version = "0.2.2" edition = "2024" license = "0BSD" # https://crates.io/category_slugs categories = [ "concurrency" ] keywords = [ "channel", "bounded" ] @@ -21,16 +21,16 @@ # https://doc.rust-lang.org/cargo/reference/manifest.html#the-badges-section [badges] maintenance = { status = "actively-developed" } [dependencies] -limq = { version = "0.3.1" } +limq = { version = "0.4.0" } parking_lot = { version = "0.12.3" } wakerizer = { version = "0.1.0" } [dev-dependencies] -tokio = { version = "1.44.1", features = ["macros", "rt", "rt-multi-thread"] } +tokio = { version = "1.44.2", features = ["macros", "rt", "rt-multi-thread"] } [package.metadata.docs.rs] rustdoc-args = ["--generate-link-to-definition"] [lints.clippy] Index: src/tx.rs ================================================================== --- src/tx.rs +++ src/tx.rs @@ -114,11 +114,11 @@ /// and wait until a [`Receiver`](super::Receiver) has make more room /// available on the queue. /// /// # Errors /// [`Error::CantFit`] means the [`Controller`] rejected the node. - /// [`Error::Closed`] means not [`Receiver`](super::Receiver)s remain. + /// [`Error::Closed`] means no [`Receiver`](super::Receiver)s remain. pub async fn send_async(&self, mut n: T) -> Result<(), Error> { // In an ideal world, there'd be a SendFuture that takes in the new node. // However, if the queue is full the node needs to be stored somewhere // until the task is woken up, and this presents a few annoying challenges. // @@ -189,14 +189,14 @@ /// If the queue has a limit and the queue is full, then the oldest node will /// be removed before the new element is added. /// /// # Errors /// [`Error::CantFit`] means the [`Controller`] rejected the node. - /// [`Error::Closed`] means not [`Receiver`](super::Receiver)s remain. + /// [`Error::Closed`] means no [`Receiver`](super::Receiver)s remain. pub fn force_send(&self, n: T) -> Result<(), Error> { let mut inner = self.sh.inner.lock(); - inner.q.force_push(n)?; + let _ = inner.q.force_push(n); drop(inner); // Have a new element in queue -- wake up a waiting receiver self.sh.wake_receivers(); @@ -206,18 +206,18 @@ /// Forcibly add an element to rhe channel, allowing the caller to determine /// how overflow is handled. /// /// # Errors /// [`Error::CantFit`] means the [`Controller`] rejected the node. - /// [`Error::Closed`] means not [`Receiver`](super::Receiver)s remain. + /// [`Error::Closed`] means no [`Receiver`](super::Receiver)s remain. pub fn force_send_oc( &self, n: T, overflow: Overflow ) -> Result<(), Error> { let mut inner = self.sh.inner.lock(); - inner.q.force_push_oc(n, overflow)?; + let _ = inner.q.force_push_oc(n, overflow)?; drop(inner); // Have a new element in queue -- wake up a waiting receiver self.sh.wake_receivers(); Index: www/changelog.md ================================================================== --- www/changelog.md +++ www/changelog.md @@ -7,10 +7,12 @@ [Details](/vdiff?from=limqch-0.2.1&to=trunk) ### Added ### Changed + +- Use `limq` `0.4.0`. ### Removed ---