@Test
public void cancel() {

    DeferredScalarSubscription<Integer> ds = new DeferredScalarSubscription<Integer>(new TestSubscriber<Integer>());
    assertTrue(ds.tryCancel());
    assertFalse(ds.tryCancel());
}