class FutureSubscriber extends CountDownLatch implements FlowableSubscriber<T>, Future<T>, Subscription {

    @Override
    public void onSubscribe(Subscription s) {
        SubscriptionHelper.setOnce(this.s, s, Long.MAX_VALUE);
    }

    public  FutureSubscriber();

}