class SafeSubscriber implements FlowableSubscriber<T>, Subscription {

    @Override
    public void onComplete() {
        if (done) {
            return;
        }
        done = true;

        if (s == null) {
            onCompleteNoSubscription();
            return;
        }


        try {
            actual.onComplete();
        } catch (Throwable e) {
            Exceptions.throwIfFatal(e);
            RxJavaPlugins.onError(e);
        }
    }

    public  SafeSubscriber(Subscriber<? super T> actual);

}