stepVerifierException.kt

@Test
fun `should throw Exception for mono`(){
  val monoError = Mono.error<Exception>(Exception())
  StepVerifier.create(mono)
            .expectError(Exception::class.java)
            .verify()
}

@Test
fun `should consume thrown exception from flux`() {
  val concat = Flux.concat(Mono.just("hello"), Mono.error(Exception()))
  StepVerifier.create(concat)
              .expectNext("hello")
              .expectError(Exception::class.java)
              .verify()
}