@Test public void cancel() { DeferredScalarSubscription<Integer> ds = new DeferredScalarSubscription<Integer>(new TestSubscriber<Integer>()); assertTrue(ds.tryCancel()); assertFalse(ds.tryCancel()); }
@Override public void cancel() { set(CANCELLED); value = null; }
DeferredScalarSubscription extends BasicIntQueueSubscription<T> { @Override public void cancel() { set(CANCELLED); value = null; } }
DeferredScalarSubscription extends BasicIntQueueSubscription<T> { @Override public void cancel() { set(CANCELLED); value = null; } DeferredScalarSubscription(Subscriber<? super T> actual); }
DeferredScalarSubscription extends BasicIntQueueSubscription<T> { @Override public void cancel() { set(CANCELLED); value = null; } DeferredScalarSubscription(Subscriber<? super T> actual); @Override final void request(long n); final void complete(T v); @Override final int requestFusion(int mode); @Nullable @Override final T poll(); @Override final boolean isEmpty(); @Override final void clear(); @Override void cancel(); final boolean isCancelled(); final boolean tryCancel(); }
DeferredScalarSubscription extends BasicIntQueueSubscription<T> { @Override public void cancel() { set(CANCELLED); value = null; } DeferredScalarSubscription(Subscriber<? super T> actual); @Override final void request(long n); final void complete(T v); @Override final int requestFusion(int mode); @Nullable @Override final T poll(); @Override final boolean isEmpty(); @Override final void clear(); @Override void cancel(); final boolean isCancelled(); final boolean tryCancel();  }