hv-collector-client-simulator/src/test/kotlin/org.onap.dcae.collectors.veshv.main/MessageFactoryTest.kt

   1 package org.onap.dcae.collectors.veshv.main
   2
   3 import org.jetbrains.spek.api.Spek
   4 import org.jetbrains.spek.api.dsl.given
   5 import org.jetbrains.spek.api.dsl.it
   6 import org.onap.dcae.collectors.veshv.main.impl.MessageFactory
   7 import kotlin.test.assertEquals
   8
   9 /**
  10  * @author Jakub Dudycz <jakub.dudycz@nokia.com>
  11  * @since June 2018
  12  */
  13 object WireFrameTest : Spek({
  14
  15     val factory = MessageFactory()
  16
  17
  18     given("no parameters") {
  19         it("should return flux with one message") {
  20             val result = factory.createMessageFlux()
  21
  22             assertEquals(1, result.count().block())
  23         }
  24     }
  25     given("messages amount") {
  26         it("should return message flux of specified size") {
  27             val result = factory.createMessageFlux(5)
  28             assertEquals(5, result.count().block())
  29         }
  30     }
  31 })