class FutureObserver extends CountDownLatch implements Observer<T>, Future<T>, Disposable {

    @Override
    public void onSubscribe(Disposable s) {
        DisposableHelper.setOnce(this.s, s);
    }

    public  FutureObserver();

}