一、Call 接口ResponseTexecute()execute 方法同步执行直接返回ResponseT。会阻塞不能在主线程用voidenqueue(CallbackTcallback)enqueue 方法异步执行回调里拿结果。Retrofit 自动切网络请求在子线程回调在主线程voidcancel()cancel 方法取消当前请求booleanisCanceled()isCanceled 方法是否已取消booleanisExecuted()isExecuted 方法是否已执行过CallTclone()clone 方法克隆一个新的 Call因为原 Call 只能执行一次二、创建 Observable1、just 方法1基本介绍just 方法直接发射已知数据publicstaticNonNullTObservableTjust(NonNullTitem1,NonNullTitem2,NonNullTitem3)2演示ObservableStringobservableObservable.just(Hello,World,!);observable.subscribe(s-System.out.println(just: s));输出结果just: Hello just: World just: !2、fromCallable 方法1基本介绍fromCallable 方法同步任务转异步publicstaticNonNullTObservableTfromCallable(NonNullCallable?extendsTcallable)2演示ObservableStringobservableObservable.fromCallable(()-{Thread.sleep(1000);return从数据库查询的结果;});observable.subscribe(s-System.out.println(fromCallable: s));输出结果fromCallable: 从数据库查询的结果3、fromIterable 方法1基本介绍fromIterable 方法遍历集合逐个发射publicstaticNonNullTObservableTfromIterable(NonNullIterable?extendsTsource)2演示ListStringlistArrays.asList(A,B,C);ObservableStringobservableObservable.fromIterable(list);observable.subscribe(s-System.out.println(fromIterable: s));输出结果fromIterable: A fromIterable: B fromIterable: C4、create 方法1基本介绍create 方法自定义 Observable 发射数据publicstaticNonNullTObservableTcreate(NonNullObservableOnSubscribeTsource)2演示ObservableObjectobservableObservable.create(emitter-{emitter.onNext(第 1 个数据);emitter.onNext(第 2 个数据);emitter.onComplete();});observable.subscribe(data-System.out.println(create 收到data),error-System.out.println(错误error),()-System.out.println(完成));输出结果create 收到第 1 个数据 create 收到第 2 个数据 完成5、defer 方法1基本介绍defer 方法每次订阅都重新创建publicstaticNonNullTObservableTdefer(NonNullSupplier?extendsNonNullObservableSource?extendsTsupplier)2演示ObservableLongobservableObservable.defer(()-Observable.just(System.currentTimeMillis()));observable.subscribe(time-System.out.println(第 1 次time));try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}observable.subscribe(time-System.out.println(第 2 次time));输出结果第 1 次1786448460769 第 2 次17864484617736、interval 方法1基本介绍interval 方法定时轮询publicstaticObservableLonginterval(longperiod,NonNullTimeUnitunit)2演示ObservableLongobservableObservable.interval(1,TimeUnit.SECONDS);observable.take(3)// 只取前 3 个避免无限输出.subscribe(num-System.out.println(心跳第 num 次));输出结果心跳第 0 次 心跳第 1 次 心跳第 2 次三、Observable 转换操作1、map 方法1基本介绍map 方法1 对 1 转换publicfinalNonNullRObservableRmap(NonNullFunction?superT,?extendsRmapper)2演示ObservableStringobservableObservable.just(123);observable.map(s-Integer.parseInt(s)).map(i-i*2).subscribe(result-System.out.println(map 结果result));输出结果map 结果2462、flatMap 方法1基本介绍flatMap 方法1 对 N 转换不保证顺序publicfinalNonNullRObservableRflatMap(NonNullFunction?superT,?extendsObservableSource?extendsRmapper)2演示ObservableStringobservableObservable.just(A,B);observable.flatMap(letter-Observable.just(letter1,letter2)).subscribe(s-System.out.println(flatMap: s));输出结果flatMap: A1 flatMap: A2 flatMap: B1 flatMap: B23经典用法App 有一个推荐关注列表需要先获取 10 个用户的 ID然后同时去服务器下载这 10 个人的头像Observable.just(1,2,3,4,5,6,7,8,9,10).flatMap(userId-apiService.getUserAvatar(userId).subscribeOn(Schedulers.io())).subscribe(avatarUrl-{displayAvatar(avatarUrl);});3、concatMap 方法1基本介绍concatMap 方法1 对 N 转换保证顺序publicfinalNonNullRObservableRconcatMap(NonNullFunction?superT,?extendsObservableSource?extendsRmapper)2演示ObservableStringobservableObservable.just(A,B,C);observable.concatMap(letter-Observable.just(letter1,letter2)).subscribe(s-System.out.println(concatMap: s));输出结果concatMap: A1 concatMap: A2 concatMap: B1 concatMap: B2 concatMap: C1 concatMap: C24、buffer 方法1基本介绍buffer 方法批量处理publicfinalObservableNonNullListTbuffer(intcount)2演示ObservableIntegerobservableObservable.range(1,10);observable.buffer(3)// 每 3 个打包成 List.subscribe(list-System.out.println(buffer: list));输出结果buffer: [1, 2, 3] buffer: [4, 5, 6] buffer: [7, 8, 9] buffer: [10]