consumeEach

inline suspend fun <T> ObservableSource<T>.consumeEach(
    action: (T) -> Unit
): Unit

Subscribes to this ObservableSource and performs the specified action for each received element.