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