@Test
public void cancel() {

    BlockingSubscriber<Integer> bq = new BlockingSubscriber<Integer>(new ArrayDeque<Object>());
    assertFalse(bq.isCancelled());
    bq.cancel();
    assertTrue(bq.isCancelled());
    bq.cancel();
    assertTrue(bq.isCancelled());
}