From 64b7e1ecaf414f879bb0d6e9c99b122994ee959c Mon Sep 17 00:00:00 2001
From: Thibault Duplessis <t@lichess.org>
Date: Sat, 1 Mar 2025 09:30:19 +0100
Subject: [PATCH] 11.7.0

---
 build.sbt                     | 2 +-
 lila/src/main/scala/Bus.scala | 9 +++++----
 2 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/build.sbt b/build.sbt
index eb8c60e..94fe43a 100644
--- a/build.sbt
+++ b/build.sbt
@@ -2,7 +2,7 @@ inThisBuild(
   Seq(
     scalaVersion  := "3.6.3",
     versionScheme := Some("early-semver"),
-    version       := "11.6.2",
+    version       := "11.7.0",
     organization  := "org.lichess",
     licenses += ("MIT" -> url("https://opensource.org/licenses/MIT")),
     publishTo     := Option(Resolver.file("file", new File(sys.props.getOrElse("publishTo", ""))))
diff --git a/lila/src/main/scala/Bus.scala b/lila/src/main/scala/Bus.scala
index a27705b..c0e4997 100644
--- a/lila/src/main/scala/Bus.scala
+++ b/lila/src/main/scala/Bus.scala
@@ -5,7 +5,6 @@ import scala.jdk.CollectionConverters.*
 import scala.reflect.Typeable
 import scala.concurrent.duration.*
 import scala.concurrent.{ ExecutionContext, Future, Promise }
-import com.github.benmanes.caffeine.cache.Scheduler
 import scalalib.future.extensions.withTimeout
 import scalalib.future.FutureAfter
 
@@ -34,6 +33,10 @@ object Bus:
   type Payload            = Matchable
   type SubscriberFunction = PartialFunction[Payload, Unit]
 
+final class Bus(initialCapacity: Int = 4096):
+
+  import Bus.*
+
   def pub[T <: Payload](payload: T)(using wc: WithChannel[T]) =
     publish(payload, wc.channel)
 
@@ -66,7 +69,6 @@ object Bus:
 
   def ask[A](channel: Channel, timeout: FiniteDuration = 2.second)(makeMsg: Promise[A] => Matchable)(using
       ExecutionContext,
-      Scheduler,
       FutureAfter
   ): Future[A] =
     val promise = Promise[A]()
@@ -78,7 +80,6 @@ object Bus:
       wc: WithChannel[T]
   )(using
       ExecutionContext,
-      Scheduler,
       FutureAfter
   ): Future[A] =
     val promise = Promise[A]()
@@ -88,7 +89,7 @@ object Bus:
     promise.future.withTimeout(timeout, s"Bus.safeAsk $channel $msg")
 
   private val bus = EventBus[Payload, Channel, Tellable](
-    initialCapacity = 4096,
+    initialCapacity = initialCapacity,
     publish = (tellable, event) => tellable ! event
   )