final OnSubscribe<T> onSubscribe;

/**

protected Single(OnSubscribe<T> f) {

this.onSubscribe = RxJavaHooks.onCreate(f);

}

/**

@Deprecated

protected Single(final Observable.OnSubscribe<T> f) {

onSubscribe = RxJavaHooks.onCreate(new SingleFromObservable<T>(f));

}

/**

public static <T> Single<T> create(OnSubscribe<T> f) {

return new Single<T>(f);

}

/**

public interface OnSubscribe<T> extends Action1<SingleSubscriber<? super T>> {

// cover for generics insanity

}

/**

@Beta

public final <R> Single<R> lift(final Operator<? extends R, ? super T> lift) {

return create(new SingleLiftObservableOperator<T, R>(this.onSubscribe, lift));

}

/**

@SuppressWarnings("unchecked")

public <R> Single<R> compose(Transformer<? super T, ? extends R> transformer) {

return ((Transformer<T, R>) transformer).call(this);

}

/**

public interface Transformer<T, R> extends Func1<Single<T>, Single<R>> {

// cover for generics insanity

}

/**

private static <T> Observable<T> asObservable(Single<T> t) {

// is this sufficient, or do I need to keep the outer Single and subscribe to it?

return Observable.create(new SingleToObservable<T>(t.onSubscribe));

}

/* *********************************************************************************************************

/**

public static <T> Observable<T> concat(Single<? extends T> t1, Single<? extends T> t2) {

return Observable.concat(asObservable(t1), asObservable(t2));

}

/**

public static <T> Observable<T> concat(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3) {

return Observable.concat(asObservable(t1), asObservable(t2), asObservable(t3));

}

/**

public static <T> Observable<T> concat(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3, Single<? extends T> t4) {

return Observable.concat(asObservable(t1), asObservable(t2), asObservable(t3), asObservable(t4));

}

/**

public static <T> Observable<T> concat(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3, Single<? extends T> t4, Single<? extends T> t5) {

return Observable.concat(asObservable(t1), asObservable(t2), asObservable(t3), asObservable(t4), asObservable(t5));

}

/**

public static <T> Observable<T> concat(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3, Single<? extends T> t4, Single<? extends T> t5, Single<? extends T> t6) {

return Observable.concat(asObservable(t1), asObservable(t2), asObservable(t3), asObservable(t4), asObservable(t5), asObservable(t6));

}

/**

public static <T> Observable<T> concat(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3, Single<? extends T> t4, Single<? extends T> t5, Single<? extends T> t6, Single<? extends T> t7) {

return Observable.concat(asObservable(t1), asObservable(t2), asObservable(t3), asObservable(t4), asObservable(t5), asObservable(t6), asObservable(t7));

}

/**

public static <T> Observable<T> concat(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3, Single<? extends T> t4, Single<? extends T> t5, Single<? extends T> t6, Single<? extends T> t7, Single<? extends T> t8) {

return Observable.concat(asObservable(t1), asObservable(t2), asObservable(t3), asObservable(t4), asObservable(t5), asObservable(t6), asObservable(t7), asObservable(t8));

}

/**

public static <T> Observable<T> concat(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3, Single<? extends T> t4, Single<? extends T> t5, Single<? extends T> t6, Single<? extends T> t7, Single<? extends T> t8, Single<? extends T> t9) {

return Observable.concat(asObservable(t1), asObservable(t2), asObservable(t3), asObservable(t4), asObservable(t5), asObservable(t6), asObservable(t7), asObservable(t8), asObservable(t9));

}

/**

public static <T> Single<T> error(final Throwable exception) {

return Single.create(new OnSubscribe<T>() {

@Override

public void call(SingleSubscriber<? super T> te) {

te.onError(exception);

}

});

}

/**

public static <T> Single<T> from(Future<? extends T> future) {

return create(new SingleFromFuture<T>(future, 0, null));

}

/**

public static <T> Single<T> from(Future<? extends T> future, long timeout, TimeUnit unit) {

if (unit == null) {

throw new NullPointerException("unit is null");

}

return create(new SingleFromFuture<T>(future, timeout, unit));

}

/**

public static <T> Single<T> from(Future<? extends T> future, Scheduler scheduler) {

return from(future).subscribeOn(scheduler);

}

/**

public static <T> Single<T> fromCallable(final Callable<? extends T> func) {

return create(new SingleFromCallable<T>(func));

}

/**

public static <T> Single<T> just(final T value) {

return ScalarSynchronousSingle.create(value);

}

/**

@SuppressWarnings({ "unchecked", "rawtypes" })

public static <T> Single<T> merge(final Single<? extends Single<? extends T>> source) {

if (source instanceof ScalarSynchronousSingle) {

return ((ScalarSynchronousSingle<T>) source).scalarFlatMap((Func1) UtilityFunctions.identity());

}

return Single.create(new OnSubscribe<T>() {

@Override

public void call(final SingleSubscriber<? super T> child) {

SingleSubscriber<Single<? extends T>> parent = new SingleSubscriber<Single<? extends T>>() {

@Override

public void onSuccess(Single<? extends T> innerSingle) {

innerSingle.subscribe(child);

}

@Override

public void onError(Throwable error) {

child.onError(error);

}

};

child.add(parent);

source.subscribe(parent);

}

});

}

/**

public static <T> Observable<T> merge(Single<? extends T> t1, Single<? extends T> t2) {

return Observable.merge(asObservable(t1), asObservable(t2));

}

/**

public static <T> Observable<T> merge(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3) {

return Observable.merge(asObservable(t1), asObservable(t2), asObservable(t3));

}

/**

public static <T> Observable<T> merge(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3, Single<? extends T> t4) {

return Observable.merge(asObservable(t1), asObservable(t2), asObservable(t3), asObservable(t4));

}

/**

public static <T> Observable<T> merge(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3, Single<? extends T> t4, Single<? extends T> t5) {

return Observable.merge(asObservable(t1), asObservable(t2), asObservable(t3), asObservable(t4), asObservable(t5));

}

/**

public static <T> Observable<T> merge(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3, Single<? extends T> t4, Single<? extends T> t5, Single<? extends T> t6) {

return Observable.merge(asObservable(t1), asObservable(t2), asObservable(t3), asObservable(t4), asObservable(t5), asObservable(t6));

}

/**

public static <T> Observable<T> merge(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3, Single<? extends T> t4, Single<? extends T> t5, Single<? extends T> t6, Single<? extends T> t7) {

return Observable.merge(asObservable(t1), asObservable(t2), asObservable(t3), asObservable(t4), asObservable(t5), asObservable(t6), asObservable(t7));

}

/**

public static <T> Observable<T> merge(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3, Single<? extends T> t4, Single<? extends T> t5, Single<? extends T> t6, Single<? extends T> t7, Single<? extends T> t8) {

return Observable.merge(asObservable(t1), asObservable(t2), asObservable(t3), asObservable(t4), asObservable(t5), asObservable(t6), asObservable(t7), asObservable(t8));

}

/**

public static <T> Observable<T> merge(Single<? extends T> t1, Single<? extends T> t2, Single<? extends T> t3, Single<? extends T> t4, Single<? extends T> t5, Single<? extends T> t6, Single<? extends T> t7, Single<? extends T> t8, Single<? extends T> t9) {

return Observable.merge(asObservable(t1), asObservable(t2), asObservable(t3), asObservable(t4), asObservable(t5), asObservable(t6), asObservable(t7), asObservable(t8), asObservable(t9));

}

/**

@SuppressWarnings("unchecked")

public static <T1, T2, R> Single<R> zip(Single<? extends T1> s1, Single<? extends T2> s2, final Func2<? super T1, ? super T2, ? extends R> zipFunction) {

return SingleOperatorZip.zip(new Single[] {s1, s2}, new FuncN<R>() {

@Override

public R call(Object... args) {

return zipFunction.call((T1) args[0], (T2) args[1]);

}

});

}

/**

@SuppressWarnings("unchecked")

public static <T1, T2, T3, R> Single<R> zip(Single<? extends T1> s1, Single<? extends T2> s2, Single<? extends T3> s3, final Func3<? super T1, ? super T2, ? super T3, ? extends R> zipFunction) {

return SingleOperatorZip.zip(new Single[] {s1, s2, s3}, new FuncN<R>() {

@Override

public R call(Object... args) {

return zipFunction.call((T1) args[0], (T2) args[1], (T3) args[2]);

}

});

}

/**

@SuppressWarnings("unchecked")

public static <T1, T2, T3, T4, R> Single<R> zip(Single<? extends T1> s1, Single<? extends T2> s2, Single<? extends T3> s3, Single<? extends T4> s4, final Func4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> zipFunction) {

return SingleOperatorZip.zip(new Single[] {s1, s2, s3, s4}, new FuncN<R>() {

@Override

public R call(Object... args) {

return zipFunction.call((T1) args[0], (T2) args[1], (T3) args[2], (T4) args[3]);

}

});

}

/**