src/main/java/io/reactivex/internal/operators/flowable/FlowableLastMaybe.java
@Override
    protected void subscribeActual(MaybeObserver<? super T> observer) {
        source.subscribe(new LastSubscriber<T>(observer));
    }
@Override
    protected void subscribeActual(MaybeObserver<? super T> observer) {
        source.subscribe(new LastSubscriber<T>(observer));
    }
TODO fuse back to Flowable