public boolean isSync() {
        return sync;
    }
@Test
    public void isSync() throws Exception {
        Subscriber subscriber = new TestSubscriber();
        Assert.assertTrue(subscriber.isSync());

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