reactive-programming相关内容

RxSwift:管理应用程序中的对象更新

我非常关心如何管理对象属性更改. 假设我有一个“汽车"类，有一些属性，如“名称"、“日期"、“价格"等 在我的视图“A"中，我显示了我从 API 中检索到的所有汽车.在视图 B &C、我可以显示和编辑视图 A 中所选汽车的特定信息(假设它是“汽车 AAA").也可以使用 API 调用刷新汽车对象以检索有关汽车的最新信息. 我希望能够更新视图 A，如果用户在另一个视图中对对象汽车执 ..
发布时间：2021-07-14 19:21:10 移动开发

使用 Javascript 进行响应式编程

我是响应式编程的新手，阅读所有这些我看不懂的文章时有点不知所措. 实际上，我是一名来自 Nodejs、Angularjs、Angular 2 和 React 的 JavaScript 开发人员. 我做什么 我一直使用 promises，用于远程数据获取、本地异步解析等......比回调更好的可测试性并满足我的需求. 我对流的理解 除非在特定情况下，我不知道流可以在哪里 ..
发布时间：2021-07-14 19:07:12 前端开发

任何同时返回输入变量和结果的 Rx 运算符?

当使用 Rx(特别是 RxJava)时，是否有一个运算符将输入变量与函数的输出一起打包，以便在下一步中同时使用? 例如，假设我从推文 ID 列表开始，我的程序 a) 执行 REST 调用以获取该推文的文本，b) 将 id 和文本保存到本地数据库中.普通的“地图"将返回步骤 a 的文本，但它会丢弃原始 ID.在代码中: Observable.from(tweet_id_list).speci ..
发布时间：2021-07-14 18:58:53 其他开发

订阅未来的可观察对象

我没有基于事件的 API(Geolocator) 我想转换为 Rx. 问题是某些操作要求取消订阅所有事件，我不想将负担传递给 Rx API 的用户. 因此，用户将订阅一些 observable，当订阅事件时，它们将发布到这些 observable. 最好的方法是什么? 我想创建一个用户订阅的主题，然后通过另一组可观察对象将事件发布给用户. 这是最好的方法吗?如果是这样 ..
发布时间：2021-07-03 19:46:35 其他开发

Akka HTTP“每个请求的参与者"图案

目前我正在尝试实施 "actor-per-request" 模式由 NET-A-PORTER devs 在 Akka HTTP 中提出.我面临的问题是文档中的任何地方都没有记录这种模式.似乎没有办法做到以下几点: IO(Http) !Http.Bind(serviceActor, "localhost", port = 38080) 如何在不使用 Spray 的情况下为每个请求使用一个 Akk ..
发布时间：2021-07-03 19:46:32 其他开发

RxJS 的循环依赖.造型孢子

我尝试使用 RxJS 为一些游戏建模.但我发现循环依赖有一些问题.所以，我将我的游戏简化为一个简单的模拟(我只留下了“移动"动作).你可以在下面找到代码(我省略了一些部分，你可以找到这里的repo) const rx = require('rx')const math = require('mathjs')const _ = require('下划线')const FIELD_SIZE = 10 ..
发布时间：2021-07-03 19:46:29 前端开发

Spring Boot 2 &Spring 5 容器混淆

我有一个 Spring Boot 1.4.3 项目.最近我提出了一个要求，我必须将日志从服务器发送到我的 Web 应用程序并在网页上打印日志.我知道 WebSockets，但我一直在寻找更好的解决方案，我遇到了响应式编程和 gRPC. Spring 在 Spring 版本 5 中支持响应式编程，但我在 gRPC 和响应式编程之间很困惑.gRPC 具有双向流，它构建在 Netty 之上，并提供 ..
发布时间：2021-07-03 19:46:25 Java开发

Rx scan()，无法从种子和另一个可观察对象生成可观察对象

我有一个种子值 Triangle (Bool) 和一个发出值 Circle (Int) 的 observable.我的目的是在每次从该 observable 发出一个值时生成一个新的 observable (Triangle, Circle)，将 Triangle 值转换为否定当前值.这是我的大理石图: 但是我无法实现它，我不知道scan 是否是正确的操作符.这是我的代码: typeali ..
发布时间：2021-07-03 19:46:20 移动开发

如何从 Observable> 转换到 Observable<List<Y>，使用将 X 作为参数的函数 &返回 Observable

我有一个方法可以无限期地(非有限地)发出用户 ID 列表. Observable>getFriendUserIds() 另一种返回特定用户 ID 的 Account 数据的方法. ObservablegetAccount(String userId) 我需要获取 getFriendUserIds() 方法返回的所有用户 ID 的 Account 数据，将它们分组在一个与用户 ID 列表相对 ..
发布时间：2021-07-03 19:46:14 Java开发

应该如何在 Rx 中实现 DistinctLatest(和缓存)运算符?

我有一个问题 在订阅时提供更新和新值作为“DistinctLatest"和完整缓存内容的缓存，社区处理得很好.提出了一个问题，即缓存和替换上述问题中定义的值的实际目标可以用 .DistinctLatest 运算符定义. 好的！似乎没有太多谈论这样的运营商.在搜索和思考时，我发现 ReactiveX:Group 和 Buffer 只是每组中的最后一项，这有点接近.为了模仿原始问题，我尝试将缓存 ..
发布时间：2021-07-03 19:46:11 C#/.NET

R Shiny - 反应式 selectInput 数据框列

我有一个仪表板，可以从 Google 分析或 CSV 上传中提取数据，然后计算转化率和平均订单价值(用于 AB 测试).我一直在尝试实现允许选择设备类别(例如(手机、平板电脑或台式机)和产品类别(例如(卡片、礼物或鲜花))的过滤器.过滤器应从数据框中动态提取，然后可在下拉列表中进行选择.我在这个论坛上看到了很多类似的例子，但在我的一生中，我一直无法让它发挥作用.我看到的案例似乎使用了observe ..
发布时间：2021-07-03 19:46:08 其他开发

RxJava - 合并的 Observable 可以随时接受更多的 Observable?

我需要一个 Observable 实现来保存一个或多个 Observable 并将它们合并.但关键是:我想在任何时候添加更多 Observables 以进行合并，我想它也可能支持删除它们. 要使其真正有效，所有订阅者都必须收到来自订阅后添加的新 Observable 的通知.除非所有合并的 Observable 都是冷的并调用 onComplete()，否则我想即使添加了更多的 Observ ..
发布时间：2021-07-03 19:46:05 其他开发

Rxjs - 订阅相互依赖的 observables

我正在学习 angular 2 和 rxjs.我有 3 个变量，A B C. B 取决于 A 的值 C 取决于 A 和 B 的值 我正在尝试设置可观察对象，以便:当 A 更新时，B 和 C 将自动更新.当 B 更新时，C 将自动更新.我尝试了两种设置，但都不令人满意. 第一次设置:B 订阅了 observable A；C 订阅 observable B withlatestfr ..
发布时间：2021-07-03 19:46:01 其他开发

鼠标左键单击在事件上使用 Reactive 扩展 IObservable 在 winform 上检测

刚开始阅读 Reactive 扩展.我正在尝试在我的 winform 上观看一个简单的鼠标左键单击.意思是任何有点击的地方(在表单上的任何控件上，包括表单)我只想显示一条消息“检测到点击".到目前为止，我有 var mouseDown = Observable.FromEvent(frmMain, "MouseDown");//缺少代码请在这里填写mouseDown.Subscribe(() = ..
发布时间：2021-07-03 19:45:58 C#/.NET