为什么 Flowable 不是 Observable

2024-01-03

为什么 Flowable 不是 Observable; Observable 接口几乎是 Flowable 的子集,它们的实现几乎相同。

为什么他们不实现一个通用接口,以便我们可以直接将 Flowable 转换为 Observable?


为什么 Flowable 不是 Observable

概念分离。我会和Flowable只是因为它可以做所有其他类型。然而,社区强烈希望以不同的类型反映主要的行为属性:Single, Maybe, Completable...

Observable 接口几乎是 Flowable 的子集

这是那些可能不每天编程的人的普遍观点。对他们来说不幸的是,类型系统和语言(Java)不允许这样的高级抽象轻松地或根本无法专业化。

另外,实施背压需要具体算法和构建块 http://akarnokd.blogspot.co.uk/并且可能会变得相当复杂。我鼓励您检查一下较难的运算符之一之间的区别:Flowable.flatMapIterable https://github.com/ReactiveX/RxJava/blob/2.x/src/main/java/io/reactivex/internal/operators/flowable/FlowableFlattenIterable.java#L218 vs Observable.flatMapIterable https://github.com/ReactiveX/RxJava/blob/2.x/src/main/java/io/reactivex/internal/operators/observable/ObservableFlattenIterable.java#L69.

为什么他们不实现一个通用接口,这样我们就可以直接将 Flowable 转换为 Observable

Flowable实现了 Reactive-Streams 接口,因此我们不能只声明Subscriber extends Observer and Subscription extends Disposable.

此外,在 v2 早期的某个时间,Observable实施的Publisher并造成大量的歧义,而手动转换将成为图书馆用户的主要痛点。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

为什么 Flowable 不是 Observable 的相关文章

随机推荐

  • onInterceptTouchEvent永远不会收到action_move

    我有一个自定义 ViewGroup 并覆盖了 onInterceptTouchEvent 它收到 ACTION DOWN 但从未收到 ACTION MOVE 据我了解 除非它返回 true 否则它应该接收所有 MotionEvent Vie
  • 如何使用 mongodb 聚合返回字符串数组

    我需要返回带有 mongodb 聚合的字符串数组 我做了以下事情 db users aggregate group id emails address 它返回 id a a com id email protected cdn cgi l
  • 如何在 PHP 中生成多个数组中项目的所有组合

    我正在尝试查找多个数组中项目的所有组合 数组的数量是随机的 可以是 2 3 4 5 每个数组中的元素数量也是随机的 例如 我有 3 个数组 arrayA array A1 A2 A3 arrayB array B1 B2 B3 arrayC
  • R如何根据长格式data.frame列计算相对值?

    我有一个像这样的数据框 我想添加一列gene richness relative 在本专栏中 gene richness价值为days 0应设置为100 作为计算基础 其他日期的相对值应该反映变化 我从几天后排序的 data frame 开
  • R:如何对数据框中定义的不同时间段内的数据进行平均?

    假设我有一个数据框 data 其中包含测量变量 x 的时间序列数据 date x 2009 10 01 00 00 10 2009 10 01 01 00 11 2009 10 01 02 00 12 2009 10 01 03 00 13
  • Qt:没有为 Windows 发行版本生成地图/pdb 文件

    我的 Qt 4 7 4 项目文件在 Windows 发行版本下不会生成 map pdb 文件 因此 事后调试是不可能的 有任何标志可以改变这一点吗 将以下内容添加到 pro 文件中 QMAKE LFLAGS RELEASE MAP QMAK
  • 如何在 Lighttpd 中设置 cookieless 域?

    我想设置禁用 cookie 的域 以提供静态内容 那么就不要在您的域上设置 cookie 严重地 这就是你所要做的 只需使用子域 并确保您不会在该域的任何位置点击任何脚本解决方案 php python 等 另外 请确保您没有启用任何会导致
  • 在 Flutter 中实现推荐奖励

    我想在我的应用程序中建立一个推荐系统 以便用户可以通过电子邮件 电话号码等 以最简单的方式 邀请他们的朋友 当确认被邀请者安装了该应用程序时 它将奖励原始邀请比如说 发件人一个月没有横幅广告 我在网上能找到的唯一参考资料是这个 https
  • HttpMediaTypeNotAcceptableException:在异常处理程序中找不到可接受的表示

    我的控制器中有以下图像下载方法 Spring 4 1 RequestMapping value get image id fileName method RequestMethod GET public ResponseBody byte
  • Spring Boot 管理页面

    我试图了解如何在我的应用程序中使用 SBAP 因为它是一个非常方便的开发工具 我正在读他们的参考指南 http codecentric github io spring boot admin 1 3 2 getting started但我不
  • 如何使用 jQuery 或 CSS 自动调整(拉伸)div 高度和宽度

    我有 4 个 div id 为 A B C 和 D 如下所示 div div div div div div div div div div Div A 和 D 具有固定的宽度和高度 Div B 具有固定宽度 我想要自动计算 Div B 的
  • Pandas 过滤器计数

    我有一些数据按一秒间隔内的出现情况进行分组 我在寻找正确的方法来过滤掉低于特定阈值的计数时遇到问题 例如我不想显示计数低于 100 的任何内容 我尝试了各种版本的过滤器 lambda 构造 但我无法在调用 count 方法之前或之后进行过滤
  • 具有布尔值和多个参数的 python 多处理

    我有一个接受多个参数的函数 其中一些是布尔值 我正在尝试将其传递给多处理pool apply async并想要传递一些带有附加名称的参数 这是我正在使用的示例脚本 from multiprocessing import Pool def t
  • 如何将环境变量传递给docker-compose up

    我正在尝试运行一个容器 我已经将镜像上传到私有 Docker 注册表 我想编写一个撰写文件来下载和部署映像 但我想将标签名称作为变量从 docker compose run 命令传递 我的撰写文件如下所示 如何将 KB DB TAG VER
  • 是否可以升级 Angularjs 属性指令以在 Angular 4 中使用?

    我已经能够升级 AngularJS 元素指令以在 Angular 4 中使用 这是示例代码 myScores js angular module app components directives myScores directive my
  • PHP 上的无限循环的 Pthreads 与 Parallel

    我正在寻找一种在 PHP 上执行多线程的方法 并遇到了 pthreads PHP API 我认为它很容易实现 但是我必须找出如何安装支持 Debian 的 ZTS 的 PHP 版本 问题是 当我查看 pthreads php net 文档时
  • 查找8086微处理器中的物理地址

    在8086微处理器中 20位地址分为16位 4位地址 其中4位二进制是段地址 当我们将4位二进制转换为十六进制时 它会变成1位十六进制 我的问题是当我们遇到计算物理地址的问题时从逻辑地址上看 给出的是一个4bit的十六进制段地址 为什么会这
  • 如何验证 Perl 中的函数参数?

    你能告诉我 Perl 中验证函数参数最明智的方法是什么吗 代码片段 sub testfunction my args my value args gt value die no value set process value testfun
  • Redux 和 React Router:结合调度和导航 (history.push)

    我对如何使用 React Router 有点一无所知history push route with Redux 换句话说 如果你将一个组件与 Redux 的连接mapDispatchToProps 你怎么放history push rout
  • 为什么 Flowable 不是 Observable

    为什么 Flowable 不是 Observable Observable 接口几乎是 Flowable 的子集 它们的实现几乎相同 为什么他们不实现一个通用接口 以便我们可以直接将 Flowable 转换为 Observable 为什么