@Test
public void postCompleteAlreadyComplete() {

    TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
    Queue<Integer> q = new ArrayDeque<Integer>();
    q.offer(1);
    AtomicLong state = new AtomicLong(QueueDrainHelper.COMPLETED_MASK);
    QueueDrainHelper.postComplete(ts, q, state, new BooleanSupplier() {
        @Override
        public boolean getAsBoolean() throws Exception {
            return false;
        }
    });
}