@Test
public void isSync() throws Exception {

    Subscriber subscriber = new TestSubscriber();
    Assert.assertTrue(subscriber.isSync());
    subscriber = new TestAsyncSubscriber();
    Assert.assertFalse(subscriber.isSync());
}