blockException.kt

@Test
fun `should throw exception while fetching person data`(){
    val personService = PersonService()
    
    assertThatThrownBy{
      personService.getPerson("name")
    }.isInstanceOf(PersonNotFound::class.java)
    .hasMessage("No person found in the database")
}

@Test
fun `should throw execption for flux of Data`() {
    val concat = Flux.concat(Mono.just("hello"), Mono.error(Exception()))
    
    assertThatThrownBy{
        concat.collectList().block()
    }.isInstanceOf(Exception::class.java)
}