From bf54f828e68809d8501311a329b410ea2b864d9f Mon Sep 17 00:00:00 2001 From: ragnar Date: Sat, 27 Apr 2024 12:16:06 +0200 Subject: [PATCH] imports --- .../main/scala/replication/ConnectionManager.scala | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/Modules/Example Replication/shared/src/main/scala/replication/ConnectionManager.scala b/Modules/Example Replication/shared/src/main/scala/replication/ConnectionManager.scala index 6b687c42a..e727f1850 100644 --- a/Modules/Example Replication/shared/src/main/scala/replication/ConnectionManager.scala +++ b/Modules/Example Replication/shared/src/main/scala/replication/ConnectionManager.scala @@ -2,18 +2,17 @@ package replication import channel.{ArrayMessageBuffer, BiChan, Ctx, MessageBuffer} import com.github.plokhotnyuk.jsoniter_scala.core.{JsonValueCodec, readFromSubArray, writeToArray} -import rdts.syntax.LocalReplicaId +import de.rmgk.delay.Async +import de.rmgk.delay.syntax.run import rdts.base.Uid +import rdts.syntax.LocalReplicaId +import reactives.default.{act, current} +import reactives.operator.{Evt, Fold, Signal} import replication.CMessage.{Identify, Payload} import replication.JsoniterCodecs.given -import de.rmgk.delay.Async -import reactives.operator.{Evt, Fold, Signal} -import reactives.default.{act, current} -import de.rmgk.delay.syntax.run import java.nio.charset.StandardCharsets -import java.util.concurrent.{ArrayBlockingQueue, BlockingDeque} -import scala.util.chaining.scalaUtilChainingOps +import java.util.concurrent.ArrayBlockingQueue class PeerRef[T](uid: Uid) { val messageQueue: ArrayBlockingQueue[T] = new ArrayBlockingQueue[T](Int.MaxValue)