diff options
| author | Jakob Odersky <jodersky@gmail.com> | 2013-03-05 15:35:02 +0100 |
|---|---|---|
| committer | Jakob Odersky <jodersky@gmail.com> | 2013-03-05 15:35:02 +0100 |
| commit | aab5f7b6b25abec2f34867af9c4e48512d97f068 (patch) | |
| tree | ef85c88389237b19f4a65932d9f91ac36d2dd81f | |
| parent | 6e7a2b16a18f8b7ccff5756a716e7671c6fadbab (diff) | |
| download | ace-aab5f7b6b25abec2f34867af9c4e48512d97f068.tar.gz ace-aab5f7b6b25abec2f34867af9c4e48512d97f068.tar.bz2 ace-aab5f7b6b25abec2f34867af9c4e48512d97f068.zip | |
add requirement in constructor to ensure sequence number is representable as a byte
| -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]]) |