class DisposableSubscriber implements FlowableSubscriber<T>, Disposable {

    @Override
    public final void onSubscribe(Subscription s) {
        if (EndConsumerHelper.setOnce(this.s, s, getClass())) {
            onStart();
        }
    }

}