diff options
| -rw-r--r-- | scala/ace/src/main/scala/com/github/jodersky/ace/Arq.scala | 2 |
1 files changed, 1 insertions, 1 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 9708023..212dd44 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 @@ -8,7 +8,7 @@ import scala.collection.mutable.HashMap 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]] { +class Arq(timeout: Int, maxResends: Int = 10, maxMessageBuffer: Int = 10) extends ReactiveLayer[Seq[Int], Seq[Int]] { require(maxMessageBuffer < 256, "max amount of messages must fit into a byte") import Arq._ |