@Test
public void preNextConnect() {

    for (int i = 0; i < TestHelper.RACE_DEFAULT_LOOPS; i++) {
        final ConnectableObservable<Integer> co = Observable.<Integer>empty().publish();
        co.connect();
        Runnable r1 = new Runnable() {
            @Override
            public void run() {
                co.test();
            }
        };
        TestHelper.race(r1, r1);
    }
}