问题标签 [reactivex]

我有一个函数，它返回一个包含来自 html 页面的列表的对象：

接下来我想做的是：

最后，返回带有替换图像 url 的原始 MediaList 对象。我想我应该在某个地方使用flatmapand from，但我不知道具体如何。

媒体列表.java：

遵循与问题 39 类似的示例：http: //reactivex.io/learnrx/

我正在尝试将方法调用search(query: String)转换为这些调用的序列。他们实现这一点的方法是创建一个，每次调用该方法时Variable我都会使用该值进行更新。querysearch(query: String)

然后我在我的init()：

如果我输入"ABC", 我的search(query: String)方法将被调用 3 次"A", "AB", "ABC"。那将被映射到seq(["A", "AB", "ABC"])with queryVariable.asObservable()。然后我将其映射到 Facebook 搜索（在 Facebook 上按姓名搜索人）。和subscribeNext我一起打印名字。如果我不使用takeUntil，它会按我的预期工作，我会得到 3 组结果，每个查询（"A", "AB", "ABC"）一组。

但是，如果我快速输入（在 Facebook 有时间响应请求之前），我只想要一个结果，用于 query "ABC"。这就是我添加takeUntil. 有了它，我希望facebookSearch(query: String)下一个调用会被忽略query，但是当前查询正在取消它，所以takeUntil我最终什么也没打印。

这是一个已知问题还是我做错了什么？

我正在尝试将数据附加到 UITableView。我在这里下载了项目表格，并使用了将数据附加到 tableView 的代码：http: //yannickloriot.com/2016/01/make-uitableview-reactive-with-rxswift/：

首先，我创建了以下变量：

然后我尝试执行以下操作：

但我收到以下警告：'Extra argument in call' on the line .bindTo。我尝试添加一个新单元并获得相同的结果。不确定它是否相关，但我已经注册了单元格。

我在这里读到，如果参数的类型不匹配，您会收到此警告：Swift - Extra Argument in call。但是看起来参数匹配得很好。

我是 Rx 的新手，希望有人能帮助我了解这里可能出了什么问题。谢谢。

======

编辑

这是我的新代码。我rx_itemsWithCellIdentifier("ChoiceCell")独自尝试过rx_itemsWithCellIdentifier("ChoiceCell", cellType: ChoiceCell.self)：

在我使用过的地方（出租车），它是一系列出租车项目。见下图：

同样，一旦我调用了 .asObservable()，我就会得到以下信息：

我设法通过删除线将这些打印出来.bindTo。如果我将该行添加回来，我会得到与以前相同的错误。

重要提示：我使用了之前链接到的文章中的代码库。如果我从 ChoiceCell 中删除，我可以复制相同的错误：

我有一个 Observable 仅用于触发flatMap/ map。所以我只需要Next事件而不需要值。对于这种垃圾值，我可以使用我自己的概念，但我想知道是否有针对它的 RxSwift 约定。

这是我正在处理的问题：

在此示例中，triggeringObservable位于rx_observer库中的某些属性上，它将让我们知道username()已准备好被调用。

有可以过滤的运营商nil吗？我最接近的是这里提到的解决方案：https ://github.com/ReactiveX/RxSwift/issues/209#issuecomment-150842686

相关摘录：

但是， after .notNil(),E仍然是可选的，因此后续的链式运算符仍然认为selfwhereObserver<E>是E可选的。所以我仍然需要一个额外的运算符：

我肯定错过了什么。这似乎是一个非常普遍的需求。

我有一个Observable去数据库和查询一些信息。我不希望我的 observable 执行时间超过 5 秒，因此我使用：

然后我也想处理错误通知，因此我使用：

myObservable然后我想知道用于进行数据库查询的代码会发生什么。它也会被终止，还是会继续运行？（这发生在 Java native 上Future.get(timeLimit)）

在 RxJS 中，我希望订阅在流中保持不变，即使流发生了变化。下面我使用间隔流来测试行为

jsbin 现场演示

如何在更改bar$流时保留订阅？更改 bar$ 后，我是否必须处理订阅并设置另一个订阅？

我觉得我开始掌握 RxSwift 的窍门——但我刚刚遇到了障碍。这是我为演示构建的一个对象（我在发布到 SO 之前对其进行了简化）。我的问题是，当上传过程中出现网络错误时，所有订阅都会被处理掉。所以当我rightBarButtonItem再次点击时，什么也没有发生。

对此建模的正确/更好的方法是什么？我不确定我PublishSubject是否正确掌握了 s 的用法！

而在ViewController.swift...

我在scala Play Framework 2.5中使用java ReactiveX（RxJava）与couchbase异步通信我想知道我的observable运行需要多长时间？我使用下面的代码定义了我的 observable。

我使用以下方法调用它

我如何测量 observable 运行需要多长时间？

提前谢谢你

弗朗西斯

如何使用 RxSwift 实现事件发射器？（一个可以发出数据的对象，该数据由订阅它的其他对象使用。）

在浏览了 Rx 文档和示例之后，我觉得自己像个彻头彻尾的白痴，仍然对如何手动将事件从 Observers 发送到 Observables 感到非常困惑。我的理解是我们有一些 Observable 可以向订阅该 Observable 的所有观察者发出带有数据的事件。但是，我对如何在 Swift 中实际实现这一点的想法为零。

这是我正在尝试实现的示例：

第二个文件：

我的大脑被炸了。我现在只是要切换到像 EmitterKit 这样的专业库，因为我显然误解了它是如何工作的。

但我需要弄清楚 Rx 是如何工作的，否则我会发疯的。帮助！