@Test
public void clear() {

    DeferredScalarSubscription<Integer> ds = new DeferredScalarSubscription<Integer>(new TestSubscriber<Integer>());
    ds.value = 1;
    ds.clear();
    assertEquals(DeferredScalarSubscription.FUSED_CONSUMED, ds.get());
    assertNull(ds.value);
}