@Test
public void rejectSyncFusion() {

    UnicastSubject<Object> p = UnicastSubject.create();
    TestObserver<Object> to = ObserverFusion.newTest(QueueFuseable.SYNC);
    p.subscribe(to);
    ObserverFusion.assertFusion(to, QueueFuseable.NONE);
}