@Test
public void testAmb3() {

    Observable<String> observable1 = createObservable(new String[] {
            "1" }, 2000, null);
    Observable<String> observable2 = createObservable(new String[] {},
            1000, null);
    Observable<String> observable3 = createObservable(new String[] {
            "3" }, 3000, null);
    Observable<String> o = Observable.create(amb(observable1,
            observable2, observable3));
    @SuppressWarnings("unchecked")
    Observer<String> observer = (Observer<String>) mock(Observer.class);
    o.subscribe(observer);
    scheduler.advanceTimeBy(100000, TimeUnit.MILLISECONDS);
    InOrder inOrder = inOrder(observer);
    inOrder.verify(observer, times(1)).onCompleted();
    inOrder.verifyNoMoreInteractions();
}