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

    @Override
    public void cancel() {
        if (SubscriptionHelper.cancel(this)) {
            queue.offer(TERMINATED);
        }
    }

    public  BlockingSubscriber(Queue<Object> queue);

}