class OnSubscribeAmb implements OnSubscribe<T> {

    public static <T> OnSubscribe<T> amb(Observable<? extends T> o1, Observable<? extends T> o2) {
        List<Observable<? extends T>> sources = new ArrayList<Observable<? extends T>>();
        sources.add(o1);
        sources.add(o2);
        return amb(sources);
    }

    private  OnSubscribeAmb(Iterable<? extends Observable<? extends T>> sources);

}