From ead4fd7743895ffe1d34e37c23eceab575fb907e Mon Sep 17 00:00:00 2001 From: Ivan Topolnjak Date: Fri, 15 Sep 2017 02:49:36 +0200 Subject: create new DifferentialSource utility --- .../scala/kamon/util/DifferentialSourceSpec.scala | 40 ++++++++++++++++++++++ 1 file changed, 40 insertions(+) create mode 100644 kamon-core-tests/src/test/scala/kamon/util/DifferentialSourceSpec.scala (limited to 'kamon-core-tests') diff --git a/kamon-core-tests/src/test/scala/kamon/util/DifferentialSourceSpec.scala b/kamon-core-tests/src/test/scala/kamon/util/DifferentialSourceSpec.scala new file mode 100644 index 00000000..0a2f83e5 --- /dev/null +++ b/kamon-core-tests/src/test/scala/kamon/util/DifferentialSourceSpec.scala @@ -0,0 +1,40 @@ +package kamon.util + +import org.scalatest.{Matchers, WordSpec} + +class DifferentialSourceSpec extends WordSpec with Matchers { + + "a Differential Source" should { + "get the difference between the last two observations" in { + val source = sourceOf(0, 0, 1, 1, 2, 3, 4, 6, 8, 10, 12, 16, 18) + val expectedDiffs = Seq(0, 1, 0, 1, 1, 1, 2, 2, 2, 2, 4, 2) + + values(expectedDiffs.length, source) should contain theSameElementsInOrderAs(expectedDiffs) + } + + "ignore decrements in observations" in { + val source = sourceOf(10, 10, 5, 5, 10, 10) + val expectedDiffs = Seq(0, 0, 0, 5, 0) + + values(expectedDiffs.length, source) should contain theSameElementsInOrderAs(expectedDiffs) + } + } + + def sourceOf(numbers: Long*): DifferentialSource = DifferentialSource(new (() => Long) { + var remaining = numbers.toList + + override def apply(): Long = { + if(remaining.isEmpty) 0 else { + val head = remaining.head + remaining = remaining.tail + head + } + } + }) + + def values(count: Int, source: DifferentialSource): Seq[Long] = { + for(_ <- 1 to count) yield source.get() + } +} + + -- cgit v1.2.3