forEach

fun <T> Publisher<T>.forEach(listener: (T?, Throwable?) -> Unit): Unit (source)

Listen each element from the publisher.