這不是源碼分析篇只是想聊一聊這些哪些地方可以用到
1just
<pre>
Observable.just("Cricket", "Football")
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(getObserver())
private Observer<String> getObserver() {
return new Observer<String>() {
@Override
public void onSubscribe(Disposable d) {
Log.d(TAG, " onSubscribe : " + d.isDisposed());
}
@Override
public void onNext(String value) {
textView.append(" onNext : value : " + value);
textView.append(AppConstant.LINE_SEPARATOR);
Log.d(TAG, " onNext : value : " + value);
}
@Override
public void onError(Throwable e) {
textView.append(" onError : " + e.getMessage());
textView.append(AppConstant.LINE_SEPARATOR);
Log.d(TAG, " onError : " + e.getMessage());
}
@Override
public void onComplete() {
textView.append(" onComplete");
textView.append(AppConstant.LINE_SEPARATOR);
Log.d(TAG, " onComplete");
}
};
}
</pre>
大家想想這個能用到哪種情況捌臊？ just（參數(shù)最多10個）
我說一種情況（控件中獲取的值领虹，然后我們會對這個值去判定，比如請假兩個時間是比對府蔗，登錄判斷是不是為null）
2map
<pre>
.map(new Function<List<你有的數(shù)據(jù)類型r>, List<你希望的數(shù)據(jù)類型>>() {
@Override
public List<你希望的數(shù)據(jù)類型> apply(List<你有的數(shù)據(jù)類型> apiUsers) throws Exception {
return （轉(zhuǎn)化的類型）;
}
})
</pre>
想一想什么情況下會用揩抡？ 當你想轉(zhuǎn)的時候（舉個例子bitmap換流）
好吧 我放棄 這篇連源碼一起分析了 要不不知道怎么去開始
第一篇我會盡量詳細點
<pre>
public static <T1, T2, R> Observable<R> zip(
ObservableSource<? extends T1> source1, ObservableSource<? extends T2> source2,
BiFunction<? super T1, ? super T2, ? extends R> zipper) {
return zipArray(Functions.toFunction(zipper), false, bufferSize(), source1, source2);
}
</pre>
這是Observable的靜態(tài)方法逗柴，
ObservableSource和Observable的關系：Observable實現(xiàn)了ObservableSource接口的抽象類
<pre>
public static <T1, T2, R> Function<Object[], R> toFunction(final BiFunction<? super T1, ? super T2, ? extends R> f) {
ObjectHelper.requireNonNull(f, "f is null");
return new Function<Object[], R>() {
@Override
public R apply(Object[] a) throws Exception {
if (a.length != 2) {
throw new IllegalArgumentException("Array of size 2 expected but got " + a.length);
}
return ((BiFunction<Object, Object, R>)f).apply(a[0], a[1]);
}
};
}
</pre>
發(fā)現(xiàn)了嗎
public interface BiFunction<T1, T2, R> {
R apply(@NonNull T1 t1, @NonNull T2 t2) throws Exception;
}
返回值都是R
這樣BiFunction就和Function聯(lián)系起來了
<pre>
public static <T, R> Observable<R> zipArray(Function<? super Object[], ? extends R> zipper,
boolean delayError, int bufferSize, ObservableSource<? extends T>... sources) {
if (sources.length == 0) {
return empty();
}
ObjectHelper.requireNonNull(zipper, "zipper is null");
ObjectHelper.verifyPositive(bufferSize, "bufferSize");
return RxJavaPlugins.onAssembly(new ObservableZip<T, R>(sources, null, zipper, bufferSize, delayError));
}
</pre>
最重要就是最后一句話
new ObservableZip<T, R>(sources, null, zipper, bufferSize, delayError)
去構(gòu)造了一個ObservableZip 可以說道這里就結(jié)束了诸狭。你會說著怎么可能先鱼？
好吧 讓我們看一個方法，下面的這個方法是ObservableZip的方法
<pre>
public void subscribeActual(Observer<? super R> s) {
ObservableSource<? extends T>[] sources = this.sources;
int count = 0;
if (sources == null) {
sources = new Observable[8];
for (ObservableSource<? extends T> p : sourcesIterable) {
if (count == sources.length) {
ObservableSource<? extends T>[] b = new ObservableSource[count + (count >> 2)];
System.arraycopy(sources, 0, b, 0, count);
sources = b;
}
sources[count++] = p;
}
} else {
count = sources.length;
}
if (count == 0) {
EmptyDisposable.complete(s);
return;
}
ZipCoordinator<T, R> zc = new ZipCoordinator<T, R>(s, zipper, count, delayError);
zc.subscribe(sources, bufferSize);
}
</pre>
注意到這個方法了嗎這是在你訂閱的時候開始在Observable.subscribe
<pre>
public final void subscribe(Observer<? super T> observer) {
ObjectHelper.requireNonNull(observer, "observer is null");
try {
observer = RxJavaPlugins.onSubscribe(this, observer);
ObjectHelper.requireNonNull(observer, "Plugin returned null Observer");
subscribeActual(observer);
} catch (NullPointerException e) { // NOPMD
throw e;
} catch (Throwable e) {
Exceptions.throwIfFatal(e);
// can't call onError because no way to know if a Disposable has been set or not
// can't call onSubscribe because the call might have set a Subscription already
RxJavaPlugins.onError(e);
NullPointerException npe = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
npe.initCause(e);
throw npe;
}
}
</pre>
這時候會調(diào)用subscribeActual方法适瓦。
突然打到這里被卡住了竿开。
<pre>
@Override
@SuppressWarnings("unchecked")
public void subscribeActual(Observer<? super R> s) {
ObservableSource<? extends T>[] sources = this.sources;
int count = 0;
if (sources == null) {
sources = new Observable[8];
for (ObservableSource<? extends T> p : sourcesIterable) {
if (count == sources.length) {
ObservableSource<? extends T>[] b = new ObservableSource[count + (count >> 2)];
System.arraycopy(sources, 0, b, 0, count);
sources = b;
}
sources[count++] = p;
}
} else {
count = sources.length;
}
if (count == 0) {
EmptyDisposable.complete(s);
return;
}
ZipCoordinator<T, R> zc = new ZipCoordinator<T, R>(s, zipper, count, delayError);
zc.subscribe(sources, bufferSize);
}
</pre>
zc.subscribe(sources, bufferSize);卡再這里 分析不下去了谱仪。 讓我們靜下心來
先讓大家看一下我疑惑的地方
sources[i].subscribe(s[i]);這里 實際上也是很讓人迷惑的地方 這是什么？
這里是把你分別獲取的Observable 發(fā)射出去德迹。 你們會有疑問 怎么發(fā)射的嗎？
首先 它會先走Observable的subscribe的方法揭芍。 下面的也是最關鍵的一步胳搞。 也是讓我迷惑的一部。也就是它去執(zhí)行誰的subscribeActual方法称杨。 我要揭露謎底了肌毅、 它走的是 你那兩個Observable參數(shù) 創(chuàng)建的時候的subscribeActual 方法。
我舉個例子
<pre>
return Observable.create(new ObservableOnSubscribe<List<User>>() {
@Override
public void subscribe(ObservableEmitter<List<User>> e) throws Exception {
if (!e.isDisposed()) {
e.onNext(Utils.getUserListWhoLovesCricket());
e.onComplete();
}
}
});
</pre>
通過這個創(chuàng)建 ,那你你執(zhí)行的就是ObservableCreate的 subscribeActual方法姑原。 懂了吧悬而。 快下班了 晚上繼續(xù)。 一會我們探討Function的作用锭汛。喜歡的或者有不同意見的歡迎留言笨奠。
