@Test
public void rejectSyncFusion() {

    UnicastProcessor<Object> p = UnicastProcessor.create();
    TestSubscriber<Object> ts = SubscriberFusion.newTest(QueueFuseable.SYNC);
    p.subscribe(ts);
    SubscriberFusion.assertFusion(ts, QueueFuseable.NONE);
}