forEach |
Listen each element from the publisher. fun <T> Publisher<T>.forEach(listener: (T?, Throwable?) -> Unit): Unit |
listenList |
Listen list of not null elements from the publisher. fun <T> Publisher<T>.listenList(listener: (List<T>?, Throwable?) -> Unit): Unit |
listenSingle |
Listen one element from the publisher. fun <T> Publisher<T>.listenSingle(listener: (T?, Throwable?) -> Unit): Unit |
map |
fun <I, O> Publisher<I>.map(mapper: (I?) -> O?): Publisher<O> |