搜索结果
查询Tags标签： observable，共有 27条记录-
RxCPP（一）编程模型入门
编程模型将涉及到以下几块内容：数据流计算范例 rxcpp库的介绍 Rx操作符 调度 flat/ concatmap的区别 更多重要的操作符数据流计算简介 在函数响应式编程(FRP)中，所有这些主题都以系统的方式结合在一起。简单地说，响应式编程就是使用异步数据流进行编程。通过对流应用各…
2022/5/29 1:21:37 人评论 次浏览 -
RxCPP（一）编程模型入门- 调度
我们已经在上一节中了解了Observables，Operators和Observers。我们已经知道，在Observables和Observers之间，我们可以应用标准的Rx运算符来过滤和转换Streams。在函数式编程的情况下，我们编写不可变函数（没有副作用的函数），不可变性的结果是无序执行的可能性。如果我…
2022/5/29 1:21:08 人评论 次浏览 -
Rxjava使用手册
创建Observables https://github.com/ReactiveX/RxJava/wiki/Creating-Observables#create 1：Observable.fromAction使用效果：Observable<Integer> observable = Observable.fromAction(() -> {System.out.println("我去，被执行了");});observable.…
2022/5/26 1:50:06 人评论 次浏览 -
【设计模式】【Python】观察者模式/监听模式
#!/usr/bin/env python # -*- coding: utf-8 -*-""" @Time ：2022/5/23 9:48 @Author ： @File ：observer.py @Version ：1.0 @Function：观察者模式/监听模式 """""" 观察者基类 """class Observer…
2022/5/24 1:21:16 人评论 次浏览 -
rxjava背压，flutterplugin迁移升级
或者这样理解：水坝在储水的过程中同样也向下游放水来保持坝内的水位，但是如果发大洪水，上游水量很大，而大坝处理能力有限，坝内的水位必定会上升甚至最终漫过大坝。在RxJava中，阻塞不一定会出现异常，但是肯定会多少对系统的性能和功能造成一定的影响。阻塞是怎么形成…
2022/1/29 17:34:57 人评论 次浏览 -
RxJava使用详解
RxJava是一种异步数据处理库，也是一种扩展的观察者模式。对于Android开发者来说，使用RxJava时也会搭配RxAndroid，它是RxJava针对Android平台的一个扩展，用于Android 开发，它提供了响应式扩展组件，使用RxAndroid的调度器可以解决Android多线程问题。 观察者模式 四大…
2022/1/26 20:04:30 人评论 次浏览 -
Spring Cloud Open Feign系列【10】Feign 、 Ribbon 重试机制源码分析
文章目录 前言Feign 重试机制Retryer接口Default 类Feign 重试机制源码分析某些疑问多次重试请求，发出请求的策略？其他异常，会被重试吗？Ribbon 重试机制RxJavaRetryHandler 接口DefaultLoadBalancerRetryHandlerRequestSpecificRetryHandlerLoadBalancerCommand使用案…
2021/12/30 14:07:35 人评论 次浏览 -
Spring Cloud Open Feign系列【10】Feign 、 Ribbon 重试机制源码分析
文章目录 前言Feign 重试机制Retryer接口Default 类Feign 重试机制源码分析某些疑问多次重试请求，发出请求的策略？其他异常，会被重试吗？Ribbon 重试机制RxJavaRetryHandler 接口DefaultLoadBalancerRetryHandlerRequestSpecificRetryHandlerLoadBalancerCommand使用案…
2021/12/30 14:07:35 人评论 次浏览 -
Spring 响应式编程 随记 -- C2 Spring 响应式编程基本概念 (二)
【 好书分享：《Spring 响应式编程》-- 京东】 2.2 使用 RxJava 响应式框架的实践 RxJava 库 是 Reactive Extensions 的 Java虚拟机实现，近似于观察者模式，迭代器模式，函数式编程的组合。 2.2.1 响应式流 = 观察者 + 迭代器 通过事件分离生产者和消费者。 迭代器模式…
2021/10/14 14:14:32 人评论 次浏览 -
Spring 响应式编程 随记 -- C2 Spring 响应式编程基本概念 (二)
【 好书分享：《Spring 响应式编程》-- 京东】 2.2 使用 RxJava 响应式框架的实践 RxJava 库 是 Reactive Extensions 的 Java虚拟机实现，近似于观察者模式，迭代器模式，函数式编程的组合。 2.2.1 响应式流 = 观察者 + 迭代器 通过事件分离生产者和消费者。 迭代器模式…
2021/10/14 14:14:32 人评论 次浏览 -
Spring 响应式编程 随记 -- C2 Spring 响应式编程基本概念 (三)
【 好书分享：《Spring 响应式编程》-- 京东】 2.2.3 生成异步序列 RxJava 可以生产一个未来的事件，还可以基于时间间隔生产一个异步事件序列。 Observable.interval(1,TimeUnit.SECONDS).subcriber(msg -> System.out.println("received: " + msg));Threa…
2021/10/14 14:14:27 人评论 次浏览 -
Spring 响应式编程 随记 -- C2 Spring 响应式编程基本概念 (三)
【 好书分享：《Spring 响应式编程》-- 京东】 2.2.3 生成异步序列 RxJava 可以生产一个未来的事件，还可以基于时间间隔生产一个异步事件序列。 Observable.interval(1,TimeUnit.SECONDS).subcriber(msg -> System.out.println("received: " + msg));Threa…
2021/10/14 14:14:27 人评论 次浏览 -
观察者模式
4.15观察者模式 4.15.1天气预报项目需求 天气预报项目需求，具体要求如下：气象站可以将每天测量到的温度，湿度，气压等等以公告的形式发布出去(比如发布到自己的网站或第三方)。需要设计开放型API，便于其他第三方也能接入气象站获取数据。提供温度、气压和湿度的接口。…
2021/9/11 23:34:48 人评论 次浏览 -
观察者模式
4.15观察者模式 4.15.1天气预报项目需求 天气预报项目需求，具体要求如下：气象站可以将每天测量到的温度，湿度，气压等等以公告的形式发布出去(比如发布到自己的网站或第三方)。需要设计开放型API，便于其他第三方也能接入气象站获取数据。提供温度、气压和湿度的接口。…
2021/9/11 23:34:48 人评论 次浏览 -
Rxjava创造操作符
rxjava 操作符kotlin 语法练习 参考 ：https://github.com/ReactiveX/RxJava/ 依赖implementation io.reactivex.rxjava2:rxandroid:2.0.2implementation io.reactivex.rxjava2:rxjava:2.2.9 经常会使用的固定式语句 1、异步订阅观察者 （切换到子线程）.subscribeOn(Sche…
2021/6/29 14:21:38 人评论 次浏览
