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