class QueueDrainSubscriber extends QueueDrainSubscriberPad4 implements FlowableSubscriber<T>, QueueDrain<U, V> {

    @Override
    public final long requested() {
        return requested.get();
    }

    public  QueueDrainSubscriber(Subscriber<? super V> actual, SimplePlainQueue<U> queue);

}