下面的這些操作符屬于單獨(dú)的rxjava-async
模塊,它們用于將同步對(duì)象轉(zhuǎn)換為Observable。
start(?)
— 創(chuàng)建一個(gè)Observable,它發(fā)射一個(gè)函數(shù)的返回值toAsync(?)
or asyncAction(?)
or asyncFunc(?)
— 將一個(gè)函數(shù)或者Action轉(zhuǎn)換為已Observable,它執(zhí)行這個(gè)函數(shù)并發(fā)射函數(shù)的返回值startFuture(?)
— 將一個(gè)返回Future的函數(shù)轉(zhuǎn)換為一個(gè)Observable,它發(fā)射Future的返回值deferFuture(?)
— 將一個(gè)返回Observable的Future轉(zhuǎn)換為一個(gè)Observable,但是并不嘗試獲取這個(gè)Future返回的Observable,直到有訂閱者訂閱它forEachFuture(?)
— 傳遞Subscriber方法給一個(gè)Subscriber,但是同時(shí)表現(xiàn)得像一個(gè)Future一樣阻塞直到它完成fromAction(?)
— 將一個(gè)Action轉(zhuǎn)換為Observable,當(dāng)一個(gè)訂閱者訂閱時(shí),它執(zhí)行這個(gè)action并發(fā)射它的返回值fromCallable(?)
— 將一個(gè)Callable轉(zhuǎn)換為Observable,當(dāng)一個(gè)訂閱者訂閱時(shí),它執(zhí)行這個(gè)Callable并發(fā)射Callable的返回值,或者發(fā)射異常fromRunnable(?)
— convert a Runnable into an Observable that invokes the runable and emits its result when a Subscriber subscribes將一個(gè)Runnable轉(zhuǎn)換為Observable,當(dāng)一個(gè)訂閱者訂閱時(shí),它執(zhí)行這個(gè)Runnable并發(fā)射Runnable的返回值runAsync(?)
— 返回一個(gè)StoppableObservable,它發(fā)射某個(gè)Scheduler上指定的Action生成的多個(gè)actions