class DeferredScalarSubscriber extends DeferredScalarSubscription<R> implements FlowableSubscriber<T> {

    @Override
    public void onComplete() {
        if (hasValue) {
            complete(value);
        } else {
            actual.onComplete();
        }
    }

    public  DeferredScalarSubscriber(Subscriber<? super R> actual);

}