ios - 在 RxSwift 中一次只执行一次 subscribe 方法-6ren

ios - 在 RxSwift 中一次只执行一次 subscribe 方法

转载作者：行者123 更新时间：2023-11-30 11:51:43

25

4

我有一个 PublishObject 对象，它由传入的数据提供(大约每秒 16 次)。当对象来得如此之快时，这可能是一种情况，即一个对象仍在处理，但新对象已准备好使用。当较早的处理没有结束他的工作时，这是阻止执行另一个处理的方法吗？

最佳答案

这称为背压，有不同的策略来处理它。

RxJava 有 .onBackPressureBuffer() 运算符，但 RxSwift 尚不支持。

也许你可以复制它的 Java 实现。

关于ios - 在 RxSwift 中一次只执行一次 subscribe 方法，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/48272368/

25

4

0

文章推荐： java - Android慢速AES解密

文章推荐： java - 在 Java 中使用 SPARQL 查找人员的位置

swift - 为什么 subscribe(subject) 返回 AnyCancellable 但 subscribe(subscriber) Void？
我正在使用 Swift Joint，但不明白两者之间的区别 func subscribe(_ subscriber: S) where S : Subscriber, Self.Failure ==
java - 为什么 Flowable.subscribe(Subscriber) 不返回 Disposable？
大多数 Flowable.subscribe() 重载返回一个 Disposable ，它可以清理流。我习惯于这样做: Disposable d = Flowable.just() .map(
angular - .subscribe(x=> ...) 和 .subscribe(next(...)) 的区别？
我正在尝试测试主题 symbol$ 的输出存在于我的组件上。具体来说，当组件属性 symbol 时，主题符号 $ 应该发出(这是正确的词吗？)已经改变。但是，我找不到测试输出到 symbol$ 的
kotlin - Rx Java，subscribe({}) 与 subscribe { } 有什么区别？
Observable.just(10,20,30,40,50) .subscribe { Consumer{ Log.d(TAG, "Where
angular - RxJS subscribe inside subscribe with actions on error
我在 subscribe 中有带有 subscribe 的代码: this.http.post('/update1', newData).subscribe( (response) => {
meteor - 比较 Meteor.subscribe() 或 this.subscribe() [Meteor + Blaze]
我有两个页面/模板，仪表板(还包含一些用户特定数据)。用户。我正在使用带有 Blaze 模板的 Meteor 1.5。登陆页面是仪表板。我在两个模板中都使用集合 Users 的通用订阅。场景
Angular 2 : Nested subscribe with second subscribe inside the loop
我刚接触 Angular2 一周! 基本上有 2 个 API 调用。第一个 API 调用为我提供了一个 json 对象数组 (queryResults)。 (第一次订阅) 在 View 中显示该数组
Angular 2 无法读取未定义类型错误 : Cannot read property 'subscribe' of undefined 的属性 'subscribe'
我已经在 stackoverflow 上尝试了很多关于修复此错误的提议，但现在我只需要问一下，因为我已经花了很多时间，现在一无所获。我有这个简单的服务: constructor(private ht
java - Spring 集成: Exception Handling on Publish/Subscribe Channels with Ordered Subscribers
给定一个配置有任务执行器的发布-订阅 channel ，如果抛出异常，是否可以中断其有序订阅者的调用？例如，在此示例中，“已工作”消息仍然由序列中的第二个服务激活器发送。我希望这种事不要发生。
java - 无法解析方法 'subscribe(anonymous org.reactivestreams.Subscriber)
我正在尝试使用 Intent to PDF 应用程序下载和发送 pdf 以显示此处显示的文件 answer of JDenais这是下载 pdf 并通过 Intent 传递它的代码。 public c
angular - 使用带有 Angular 的 rxjs .subscribe 防止厄运金字塔 - 压平 .subscribes 的数量
我目前正在调查 RxJS's .merge但是我也会在这里问这个问题，因为我发现这里的解释有时非常精彩。好的，我有一个根据用户输入打开模态窗口的表单，我订阅模态关闭事件并传回一些我将在调用/订阅服务
angular - 类型 'subscribe' 中的属性 'ObservableMedia' 不可分配给基本类型 'Subscribable' 中的同一属性
我刚刚对我的 Angular 6 应用程序进行了 ng 升级，现在我得到: ERROR in node_modules/@angular/flex-layout/core/typings/observ
publish-subscribe - 处理事件驱动架构中的多事件依赖
如果您有一个事件驱动的架构并且订阅事件的服务在继续创建链中的下一个事件之前必须等待多个事件(相同类型)，那么最佳实践是什么？一个例子是图书订单处理服务，它必须等待订单中的每一本书都被仓库处理，然后再
javascript - subscribe() 后获取返回变量的值
我使用下面的代码进行异步调用，我想知道在 getData() 函数中生成的 data 的值，但是，我得到 undefined 因为调用还没有解决。有什么办法可以解决吗？ getData(address
javascript - 无法获取未定义或空引用的属性 'subscribe'
我在订阅我的 HTML 页面中的下拉值更改时遇到实现 knockout Js 的问题。这是我的 HTML Request Types :
javascript - 异步使用 subscribe()
函数定义 resetComponent(){ console.log("1st"); ... this.background = { }; this.uploadMode = fals
android - @Subscribe 方法为同一事件调用多次
在我的代码中，我正在使用 @Subscribe 注释来监听事件: @Subscribe public void orderUpdate(OrderUpdateEvent event) 我的问题是，对于
javascript - .subscribe() 函数有什么作用？
我正在使用 Angular2 和 NodeJS 编写 API，我正在为我的 ِAPI 实现服务，该 API 应该获取任务列表并显示它。这是任务服务: import {Injectable} from
Angular 无法读取未定义的属性 'subscribe'
我正在尝试使用来自服务器的 json 响应创建动态菜单，但出现此错误: MenuComponent.html:4 ERROR TypeError: Cannot read property 'subs
Angular2 - 无法读取嵌套调用中未定义的属性 'subscribe'
我查看了许多资源，包括 this , this和 this ，但我一直无法达到预期的效果。我要做的就是验证用户(使用 firebase)，然后在验证后加载他们的配置文件并将其存储在变量 userPr

首页

博学

6Ren·AI

商城

ios - 在 RxSwift 中一次只执行一次 subscribe 方法