void () { MergingUpdateQueue queue = new MergingUpdateQueue(getTestName(false), 1000_000, true, null, getTestRootDisposable(), null, Alarm.ThreadToUse.POOLED_THREAD); Update update = new Update(this) { @Override public void run() { } }; queue.queue(update); assertFalse(update.isRejected()); Disposer.dispose(queue); assertTrue(update.isRejected()); }