suspend fun consumeEach(action: suspend (T) -> Unit): Unit
iterates over all elements from the publisher