diff options
| -rw-r--r-- | scala/ace/src/main/scala/com/github/jodersky/ace/Arq.scala | 2 |
1 files changed, 2 insertions, 0 deletions
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]]) |