@CheckReturnValue
    @BackpressureSupport(BackpressureKind.PASS_THROUGH)
    @SchedulerSupport(SchedulerSupport.NONE)
    public final Flowable<T> doOnSubscribe(Consumer<? super Subscription> onSubscribe) {
        return doOnLifecycle(onSubscribe, Functions.EMPTY_LONG_CONSUMER, Functions.EMPTY_ACTION);
    }
@ CheckReturnValue @ BackpressureSupport ( BackpressureKind . PASS_THROUGH ) @ SchedulerSupport ( SchedulerSupport . NONE ) public final Flowable < T > doOnSubscribe ( Consumer < ? super Subscription > onSubscribe ) { return doOnLifecycle ( onSubscribe , Functions . EMPTY_LONG_CONSUMER , Functions . EMPTY_ACTION ) ; }
Modifies the source {@code Publisher} so that it invokes the given action when it is subscribed from
its subscribers. Each subscription will result in an invocation of the given action except when the
source {@code Publisher} is reference counted, in which case the source {@code Publisher} will invoke
the given action for the first subscription.
<p>
<img width="640" height="390" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/doOnSubscribe.png" alt="">
<dl>
<dt><b>Backpressure:</b></dt>
<dd>The operator doesn't interfere with backpressure which is determined by the source {@code Publisher}'s
backpressure behavior.</dd>
<dt><b>Scheduler:</b></dt>
<dd>{@code doOnSubscribe} does not operate by default on a particular {@link Scheduler}.</dd>
</dl>

@param onSubscribe
the Consumer that gets called when a Subscriber subscribes to the current {@code Flowable}
@return the source {@code Publisher} modified so as to call this Consumer when appropriate
@see <a href="http://reactivex.io/documentation/operators/do.html">ReactiveX operators documentation: Do</a>