问题标签 [rx-java]

我最近看到了这个关于 Elm 反应式编程的有趣演示。

这让我想知道用于实现马里奥游戏的语言结构（在显示的演示文稿中，以及在下图中）是否可以映射到纯 JavaFX 或结合 RxJava 的 JavaFX 中的类似高级语言结构？

换句话说，是否有可能在单独的 JavaFX 或 JavaFX+RxJava 中使用相同的概念抽象（即时间相关值）来表达在 Elm 中实现的马里奥游戏？

因此，如果有经验的 1）JavaFX 程序员或有经验的 2）JavaFX+RxJava+Functional 程序员想要将马里奥游戏从 Elm 移植到 1）JavaFX 或 2）JavaFX+RxJava，那么哪个程序员可以通过使用类似的高Elm 中使用的级别抽象？

我想到的 JavaFX 的抽象是绑定，而 JavaFX+RxJava 的抽象是绑定+Observables/Subjects/Subscription。

你什么时候在RxJava中使用mapvs ？flatMap

比如说，我们想要将包含 JSON 的文件映射到包含 JSON 的字符串——

使用map，我们必须以Exception某种方式处理。但是怎么做？：

使用flatMap，它更冗长，但Observables如果我们选择其他地方甚至重试，我们可以将问题转发到链下并处理错误：

我喜欢 的简单性，但（不是冗长）map的错误处理。flatmap我还没有看到任何关于这个浮动的最佳实践，我很好奇它是如何在实践中使用的。

Groovy verticle (Bar.start) groovy.lang.MissingMethodException 中的异常：没有方法签名：静态 rx.Observable.create() 适用

类加载器问题？没有把握。 Vertx 文档建议container.deployVerticle verticles 将使用父类加载器。

马文：

Vert.x 版本：2.1M5

谢谢

我使用其原生 Enumerator 构造在 Play 中成功设置了一个 websocket，调用了一些返回字符串的代码：

现在我希望我的operation函数返回一个rx.lang.scala.Observable[String]而不是一个字符串，并且我想在它进入后立即输出任何字符串。如何将此 Observable 映射到 a play.api.libs.iteratee.Enumerator？

我正在尝试对n项目进行一些异步工作，并等待所有项目完成后再继续。

我应该在该whatfunc?位置放置什么以使订阅的 onComplete 触发一次？

谢谢

我有一个我订阅了两次的 PublishSubject。第一个订阅者只计算处理的项目数，这个值总是与我通过观察者发送的值相匹配。但是，另一个订阅者正在使用缓冲区，而我经常 (75%) 没有收到通过观察者的所有项目。我是否使用错误的缓冲区？在我停止发送给观察者以确保所有项目都得到处理后，我等待的时间超过了时间跨度。

我正在尝试序列化订阅以通过网络发送。我正在使用 Scala，并执行以下操作：

但是，我收到错误：

（准确地说，我正在使用 Akka 并尝试将通知发送到远程参与者。但我认为这个问题比这更普遍）。

似乎它拒绝序列化OnNext该类，该类实际上是 的子类，它是伴生对象Notification的内部类：rx.lang.scala.Notification

http://rxscala.github.io/scaladoc/#rx.lang.scala.Notification $$OnNext

...而且我想我在 java 文档中的某处看到无法序列化内部非静态类。

我对此的理解正确吗？如果是这样，这是 rx-java 的类层次结构的限制吗？或者有什么方法可以解决这个问题，并序列化Notifications？

我想这是一个线程问题（某种垃圾收集），因为AsyncTask没有运行也没有实例化。当我持有对实例化AsyncTask的引用并且仅从订阅中调用.execute时，它​​可以工作。

我知道合乎逻辑的做法是不要在订阅中使用AsyncTask 。我正处于从经常性 AsyncTask 迁移的过程中。后来我将发送逻辑重构为非 AsyncTask 类，一切都很好。

我只是好奇为什么这首先不起作用。是因为 Timer 在 Async 任务运行之前就结束了吗？即OnNext在任务之前结束，是否通过在OnComplete上结束计时器线程？

但我真正想要并最终做到的是：

编辑1：

我删除了.observeOn(Schedulers.newThread())哪些是多余的Observable.interval

它们之间有什么相同点和不同点，看起来 Java Parallel Stream 具有 RXJava 中可用的一些元素，对吗？

感觉好像我在这里遗漏了一些东西，但是我曾经这样做过：

我似乎不再能够简单地使用调度程序来运行后台任务，而无需管理取消订阅（https://github.com/Netflix/RxJava/wiki/Scheduler和https://github.com/Netflix/ RxJava/blob/master/rxjava-core/src/main/java/rx/Scheduler.java）。

是否有 0.18 的模式可以让我轻松运行 doWhatever，而无需跟踪工作人员、取消订阅等？

似乎你可以这样做：

但这似乎需要做更多的工作，（尤其是对于 android.mainThread 调度程序）。

我在这里错过了什么？