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

    @Override
    public void onError(Throwable t) {
        value = null;
        actual.onError(t);
    }

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

}