Searched refs:singleNotification (Results 1 – 3 of 3) sorted by relevance
42 val singleNotification = flux.materialize().toIterable().single() in checkErroneous() constant43 checker(singleNotification.throwable) in checkErroneous()
22 val singleNotification = observable.materialize().blockingSingle() in checkErroneous() constant23 val error = singleNotification.error ?: error("Excepted error") in checkErroneous()
23 val singleNotification = observable.materialize().blockingSingle() in checkErroneous() constant24 val error = singleNotification.error ?: error("Excepted error") in checkErroneous()