diff options
| author | Jakob Odersky <jodersky@gmail.com> | 2013-03-26 17:27:35 +0100 |
|---|---|---|
| committer | Jakob Odersky <jodersky@gmail.com> | 2013-03-26 17:27:35 +0100 |
| commit | 32fb911a2aaca66948441e7c12f733217562879a (patch) | |
| tree | bca9f90baaee64bd9725bc0e37a4bfed4030ae39 | |
| parent | aab5f7b6b25abec2f34867af9c4e48512d97f068 (diff) | |
| download | ace-32fb911a2aaca66948441e7c12f733217562879a.tar.gz ace-32fb911a2aaca66948441e7c12f733217562879a.tar.bz2 ace-32fb911a2aaca66948441e7c12f733217562879a.zip | |
increase default ARQ resends from 5 to 10
| -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._ |