@CheckReturnValue
    @BackpressureSupport(BackpressureKind.NONE)
    @SchedulerSupport(SchedulerSupport.NONE)
    public final Disposable forEach(Consumer<? super T> onNext) {
        return subscribe(onNext);
    }
@CheckReturnValue
    @BackpressureSupport(BackpressureKind.NONE)
    @SchedulerSupport(SchedulerSupport.NONE)
    public final Disposable forEach(Consumer<? super T> onNext) {
        return subscribe(onNext);
    }
@ CheckReturnValue @ BackpressureSupport ( BackpressureKind . NONE ) @ SchedulerSupport ( SchedulerSupport . NONE ) public final Disposable forEach ( Consumer < ? super T > onNext ) { return subscribe ( onNext ) ; }
Subscribes to the {@link Publisher} and receives notifications for each element.
<p>
Alias to {@link #subscribe(Consumer)}
<dl>
<dt><b>Backpressure:</b></dt>
<dd>The operator consumes the source {@code Publisher} in an unbounded manner (i.e., no
backpressure is applied to it).</dd>
<dt><b>Scheduler:</b></dt>
<dd>{@code forEach} does not operate by default on a particular {@link Scheduler}.</dd>
</dl>

@param onNext
{@link Consumer} to execute for each item.
@return
a Disposable that allows canceling an asynchronous sequence
@throws NullPointerException
if {@code onNext} is null
@see <a href="http://reactivex.io/documentation/operators/subscribe.html">ReactiveX operators documentation: Subscribe</a>
Subscribes to the { @link Publisher } and receives notifications for each element . <p > Alias to { @link #subscribe ( Consumer ) } <dl > <dt > <b > Backpressure : < / b > < / dt > <dd > The operator consumes the source { @code Publisher } in an unbounded manner ( i . e . no backpressure is applied to it ) . < / dd > <dt > <b > Scheduler : < / b > < / dt > <dd > { @code forEach } does not operate by default on a particular { @link Scheduler } . < / dd > < / dl >