@Test
public void testSubscribeMultipleTimes() {

    OnSubscribeFromIterable<Integer> o = new OnSubscribeFromIterable<Integer>(Arrays.asList(1, 2, 3));
    TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
    o.call(ts);
    ts.assertReceivedOnNext(Arrays.asList(1, 2, 3));
    ts = new TestSubscriber<Integer>();
    o.call(ts);
    ts.assertReceivedOnNext(Arrays.asList(1, 2, 3));
    ts = new TestSubscriber<Integer>();
    o.call(ts);
    ts.assertReceivedOnNext(Arrays.asList(1, 2, 3));
}