inline suspend fun <T> Publisher<T>.consumeEach( action: (T) -> Unit): Unit
Subscribes to this Publisher and performs the specified action for each received element.