From aab5f7b6b25abec2f34867af9c4e48512d97f068 Mon Sep 17 00:00:00 2001 From: Jakob Odersky Date: Tue, 5 Mar 2013 15:35:02 +0100 Subject: add requirement in constructor to ensure sequence number is representable as a byte --- scala/ace/src/main/scala/com/github/jodersky/ace/Arq.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/scala/ace/src/main/scala/com/github/jodersky/ace/Arq.scala b/scala/ace/src/main/scala/com/github/jodersky/ace/Arq.scala index f7c4376..9708023 100644 --- a/scala/ace/src/main/scala/com/github/jodersky/ace/Arq.scala +++ b/scala/ace/src/main/scala/com/github/jodersky/ace/Arq.scala @@ -9,6 +9,8 @@ import scala.collection.mutable.Queue import scala.util.Success class Arq(timeout: Int, maxResends: Int = 5, maxMessageBuffer: Int = 10) extends ReactiveLayer[Seq[Int], Seq[Int]] { + require(maxMessageBuffer < 256, "max amount of messages must fit into a byte") + import Arq._ case class OpenMessage(data: Seq[Int], promise: Promise[Seq[Int]]) -- cgit v1.2.3