@Test
public void queueSubscriptionSyncRejected() {

    DeferredScalarSubscription<Integer> ds = new DeferredScalarSubscription<Integer>(new TestSubscriber<Integer>());
    assertEquals(QueueFuseable.NONE, ds.requestFusion(QueueFuseable.SYNC));
}