RxJavaUtils 工具类 public class RxJavaUtils {public static <T> ObservableTransformer<T, T> applySchedulers() {return new ObservableTransformer<T, T>() {@Overridepublic ObservableSource<T> apply(Observab

示例一 ： 将Integer 转 String 将一个发射整数的Observable转换为发射字符串的Observable。 // private ObservableTransformer<Integer, String> transformer() {// return new ObservableTransformer<Integer, String>() {//

compose 与 ObservableTransformer ： //操作被观察者（abstract class Observable<T> implements ObservableSource<T> ）//将源ObservableSource整体转换//通过对它应用特定的Transformer函数来转换ObservableSource。 //此方法在ObservableSource本身