class BlockingSubscriber extends AtomicReference<Subscription> implements FlowableSubscriber<T>, Subscription {

    @Override
    public void onSubscribe(Subscription s) {
        if (SubscriptionHelper.setOnce(this, s)) {
            queue.offer(NotificationLite.subscription(this));
        }
    }

    public  BlockingSubscriber(Queue<Object> queue);

}