class MaybeCache extends Maybe<T> implements MaybeObserver<T> {

    @SuppressWarnings("unchecked")
    @Override
    public void onError(Throwable e) {
        this.error = e;
        for (CacheDisposable<T> inner : observers.getAndSet(TERMINATED)) {
            if (!inner.isDisposed()) {
                inner.actual.onError(e);
            }
        }
    }

    @SuppressWarnings("unchecked") public  MaybeCache(MaybeSource<T> source);

}