Skip to content

Commit

Permalink
TSP-370 wait enhancement
Browse files Browse the repository at this point in the history
  • Loading branch information
trolley813 committed Nov 26, 2021
1 parent 6b65243 commit 2aa9aec
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ case class WaitAccumState[T](windowQueue: m.Queue[(Idx, Time)], lastFail: Boolea
val waitStart = if (lastTime._2.toMillis != 0 && Try(outputs.head._2.plus(window) < outputs.last._2).getOrElse(false)) {
outputs.headOption
} else {
Some(lastTime)
Some(cleanedWindowQueue.lastOption.getOrElse(lastTime))
}
val waitEnd = outputs.lastOption

Expand Down

0 comments on commit 2aa9aec

Please sign in to comment.