问题标签 [reactivex]

defer有人可以解释一下和create方法之间的区别Observable吗？我不明白什么时候应该使用defer，什么时候应该使用create..

参考：

推迟：http ://reactivex.io/documentation/operators/defer.html

创建：http ://reactivex.io/documentation/operators/create.html

谢谢

在新版本中，reactiveX 引入了 Single，作为 Observable 的变体 http://reactivex.io/documentation/single.html

这很好，因为在我当前的用例中，我有多个执行，每个执行只返回一个结果。因此，如果我从使用 Observable 更改为 Single 将是有意义的。

但是作为我用例的一部分，对于上面的多次执行，我需要稍后将它们连接到一个 Observable 流中（以从上述所有执行中获取结果）。

所以现在我的问题是，在性能方面什么更有益？

1. 每次执行都使用 Observable，尽管我知道执行只会返回 1 个结果。

或者

2. 每次执行都使用 Single ，并且仅在我以后需要连接流时才将它们转换为 Observable ？

谢谢你。

我是 Android 和 Java 开发的新手。当我从 GitHub 导入一些第 3 部分库时，它需要 rx (ReactiveX) 包。从 ReactiveX 构建代码时，它抱怨包sun.misc不存在。rx 包Unsafe在这里使用。

我的 Android Studio 版本是 1.5.1 我尝试了 Java 1.8.0_73 和 74，它们都不起作用。sun.misc.Unsafe但是，在 Windows 中的 Netbeans 8.1 中创建 Java 项目时导入没有问题。

我的 JDK 是 64 位的。

我试图搜索互联网，但没有找到答案。请帮忙。

我有这段代码：

它应该监听任何一个指定的通知并在任何一个被触发时进行处理。

但是，这不会编译。我收到以下错误：

那我应该如何将这两个信号合并为一个呢？

下面的代码没有将数据记录到控制台窗口，也没有抛出任何异常，Transpiler 也没有显示任何错误，我正在研究angular 2.0.0-beta.7 我从 4 开始就一直在寻找解决这个问题小时，但无法找出解决方案。

app.component.ts如下

索引.html

tsconfig.json

包.json

我有 2 个 Observables，a并且b. 我想像这样组合它们：

也就是说，我希望 Observable 的结果b在a.

我正在使用reactivex/rxjs，但只是一个概念提示就足够了。先感谢您！

我知道已经提出过这类问题，并且我还提到了所有已回答的问题，但我仍然无法解决问题。这个错误正是在我部署时发生的， import 'rxjs/add/operator/fromArray';除了这个import，Observable.fromArray代码可以完美运行。我在角度 2.0.0-beta.7

错误抛出到控制台

app.component.ts

索引.html

tsconfig.json

包.json

我正在使用 RxSwift，想知道 subscribeNext 和 bindNext 有什么区别？

感谢您的输入。

我试图依靠反应式编程与许多订阅者分享 http 调用的结果。同时我希望能够再次执行呼叫（刷新）。

我从一个执行 http 调用的冷 Observable 开始，然后立即完成。

我想包装它以获得一个像这样工作的热可观察对象：每个订阅者在订阅时应该总是收到最后一个事件（如果有的话），并且在取消订阅之前收到所有其他事件。我应该有一种方法（该可观察的外部）来触发刷新，从而触发所有订阅者的新事件。

更详细：

对于由retrofit2. 为了完整起见，这是我的服务接口

我要求改造服务：

从服务中我得到了可观察的：

这是一个冷的observable，每次调用它都会执行 http 调用subscribe()，然后立即完成。

我想公开一个热门的observable，我读过我可以这样做：

这样，http 调用首先subscribe()在其上执行，如果我多次订阅，所有这些都将“连接”到同一个coldObservable.

调用完成后，如果我subscribe()再次调用什么都不会发生，甚至没有回调完成。

相反，我希望它接收最后一个事件。

如果用户请求它，我想强制刷新（重复 http 调用）。所有订阅者都应该收到新的结果/错误。

我想象这样的事情：

触发的刷新应该在theSmartObservable.

我如何构建这样一个可观察的？

我希望我解释了自己，如果没有，请在评论中说明。

为什么它们用于不同类型的任务？在处理计算任务与 io 任务时，它们有何不同？

Schedulers.computation() - 用于计算工作，例如事件循环和回调处理；不要将此调度程序用于 I/O（使用 Schedulers.io( ) 代替）；默认情况下，线程数等于处理器数

Schedulers.io( ) - 用于 I/O 密集型工作，例如阻塞 I/O 的异步性能，此调度程序由一个线程池支持，该线程池将根据需要增长；对于普通的计算工作，切换到 Schedulers.computation()；Schedulers.io() 默认是一个 CachedThreadScheduler，类似于一个带有线程缓存的新线程调度器