@Override
    protected void subscribeActual(SingleObserver<? super T> observer) {
        source.subscribe(new LastSubscriber<T>(observer, defaultItem));
    }
@Override
    protected void subscribeActual(SingleObserver<? super T> observer) {
        source.subscribe(new LastSubscriber<T>(observer, defaultItem));
    }
@ Override protected void subscribeActual ( SingleObserver < ? super T > observer ) { source . subscribe ( new LastSubscriber < T > ( observer , defaultItem ) ) ; }
TODO fuse back to Flowable
TODO fuse back to Flowable