Single<Model> xm = Single.create((SingleOnSubscribe<Model>) emitter -> {System.out.println("do some future task");emitter.onSuccess(new Model("小明", 6));});Single<Model> xh = Single.create((SingleOnSubscribe<Model>) emitter -> {System.out.println("do some future task");emitter.onSuccess(new Model("小红", 6));});Single<Model> xhMap = xh.map(it -> new Model(it.name + "map小红袄", it.age + 1) );Single<Model> xhFlatMap = xh.flatMap(it -> Single.create((SingleOnSubscribe<Model>) emitter -> {emitter.onSuccess(new Model(it.name + "flatMap大红", 16));}));Single<List<Model>> zip = Single.zip(xm, xhMap, xhFlatMap, (s1, s2, s3) -> Lists.newArrayList(s1, s2, s3));SingleObserver<List<Model>> xwObserver = new SingleObserver<List<Model>>() {@Overridepublic void onSubscribe(Disposable d) {}@Overridepublic void onSuccess(List<Model> models) {System.out.println(models.toString());}@Overridepublic void onError(Throwable e) {}};zip.subscribe(xwObserver);

public static <T> Single<T> create(SingleOnSubscribe<T> source) {ObjectHelper.requireNonNull(source, "source is null");return RxJavaPlugins.onAssembly(new SingleCreate<T>(source));}

public final <R> Single<R> map(Function<? super T, ? extends R> mapper) {ObjectHelper.requireNonNull(mapper, "mapper is null");return RxJavaPlugins.onAssembly(new SingleMap<T, R>(this, mapper));}

public final void subscribe(SingleObserver<? super T> subscriber) {ObjectHelper.requireNonNull(subscriber, "subscriber is null");subscriber = RxJavaPlugins.onSubscribe(this, subscriber);subscribeActual(subscriber);
}

protected void subscribeActual(SingleObserver<? super R> observer) {SingleSource<? extends T>[] sources = this.sources;int n = sources.length;if (n == 1) {sources[0].subscribe(new SingleMap.MapSingleObserver<T, R>(observer, new SingletonArrayFunc()));return;}ZipCoordinator<T, R> parent = new ZipCoordinator<T, R>(observer, n, zipper);observer.onSubscribe(parent);for (int i = 0; i < n; i++) {if (parent.isDisposed()) {return;}SingleSource<? extends T> source = sources[i];if (source == null) {parent.innerError(new NullPointerException("One of the sources is null"), i);return;}source.subscribe(parent.observers[i]);}}

public final class SingleCreate<T> extends Single<T> {final SingleOnSubscribe<T> source;public SingleCreate(SingleOnSubscribe<T> source) {this.source = source;}@Overrideprotected void subscribeActual(SingleObserver<? super T> s) {Emitter<T> parent = new Emitter<T>(s);s.onSubscribe(parent);try {source.subscribe(parent);} catch (Throwable ex) {Exceptions.throwIfFatal(ex);parent.onError(ex);}}」