From 4e2657a231093b106b82c788255d44bccd45a24d Mon Sep 17 00:00:00 2001
From: Jasper Moeys <jaspermoeys@hotmail.com>
Date: Tue, 28 Jan 2025 16:01:39 +0100
Subject: [PATCH] Add message to requirements

---
 .../cats/effect/kernel/testkit/TestContext.scala      |  2 +-
 .../src/main/scala/cats/effect/std/Backpressure.scala |  2 +-
 std/shared/src/main/scala/cats/effect/std/Queue.scala | 11 +++++++----
 3 files changed, 9 insertions(+), 6 deletions(-)

diff --git a/kernel-testkit/shared/src/main/scala/cats/effect/kernel/testkit/TestContext.scala b/kernel-testkit/shared/src/main/scala/cats/effect/kernel/testkit/TestContext.scala
index 11a51b69b7..c4857fceb7 100644
--- a/kernel-testkit/shared/src/main/scala/cats/effect/kernel/testkit/TestContext.scala
+++ b/kernel-testkit/shared/src/main/scala/cats/effect/kernel/testkit/TestContext.scala
@@ -118,7 +118,7 @@ final class TestContext private (_seed: Long) extends ExecutionContext { self =>
   }
 
   def advance(time: FiniteDuration): Unit = {
-    require(time > Duration.Zero)
+    require(time > Duration.Zero, "time must be > 0")
     stateRef.currentNanos.addAndGet(time.toNanos)
     ()
   }
diff --git a/std/shared/src/main/scala/cats/effect/std/Backpressure.scala b/std/shared/src/main/scala/cats/effect/std/Backpressure.scala
index ab6ed4cc3f..93e92bd8d7 100644
--- a/std/shared/src/main/scala/cats/effect/std/Backpressure.scala
+++ b/std/shared/src/main/scala/cats/effect/std/Backpressure.scala
@@ -59,7 +59,7 @@ object Backpressure {
       strategy: Strategy,
       bound: Int
   )(implicit GC: GenConcurrent[F, ?]): F[Backpressure[F]] = {
-    require(bound > 0)
+    require(bound > 0, "bound must be > 0")
     val notAcquired: F[None.type] = GC.pure(None)
 
     Semaphore[F](bound.toLong).map(sem =>
diff --git a/std/shared/src/main/scala/cats/effect/std/Queue.scala b/std/shared/src/main/scala/cats/effect/std/Queue.scala
index 9a7cde2c6d..226ad926b3 100644
--- a/std/shared/src/main/scala/cats/effect/std/Queue.scala
+++ b/std/shared/src/main/scala/cats/effect/std/Queue.scala
@@ -129,7 +129,10 @@ object Queue {
    */
   def unsafeBounded[F[_], A](capacity: Int)(
       implicit F: Async[F]): F[unsafe.BoundedQueue[F, A]] = {
-    require(capacity > 1 && capacity < Short.MaxValue.toInt * 2)
+    require(
+      capacity > 1 && capacity < Short.MaxValue.toInt * 2,
+      "capacity must be > 1 and < 32768"
+    )
     F.delay(new BoundedAsyncQueue(capacity))
   }
 
@@ -509,7 +512,7 @@ object Queue {
       implicit F: GenConcurrent[F, ?]
   ) extends AbstractQueue(capacity, state) {
 
-    require(capacity > 0)
+    require(capacity > 0, "capacity must be > 0")
 
     protected def onOfferNoCapacity(
         s: State[F, A],
@@ -595,7 +598,7 @@ object Queue {
   private abstract class BaseBoundedAsyncQueue[F[_], A](capacity: Int)(implicit F: Async[F])
       extends Queue[F, A] {
 
-    require(capacity > 1)
+    require(capacity > 1, "capacity must be > 1")
 
     protected[this] val buffer = new UnsafeBounded[A](capacity)
 
@@ -1009,7 +1012,7 @@ object Queue {
 
   // ported with love from https://github.com/JCTools/JCTools/blob/master/jctools-core/src/main/java/org/jctools/queues/MpmcArrayQueue.java
   private[effect] final class UnsafeBounded[A](bound: Int) {
-    require(bound > 1)
+    require(bound > 1, "bound must be > 1")
 
     private[this] val buffer = new Array[AnyRef](bound)