DeferredScalarSubscription extends BasicIntQueueSubscription<T> { @Override public final int requestFusion(int mode) { if ((mode & ASYNC) != 0) { lazySet(FUSED_EMPTY); return ASYNC; } return NONE; } 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();  }
@Test public void queueSubscriptionSyncRejected() { DeferredScalarSubscription<Integer> ds = new DeferredScalarSubscription<Integer>(new TestSubscriber<Integer>()); assertEquals(QueueFuseable.NONE, ds.requestFusion(QueueFuseable.SYNC)); }