问题标签 [rx-java3]

有一个控制器：

拳头通话绝对没问题。但是，如果在 CircuitBreaker 打开时发生第二次调用，则不会因相同的异常而失败。相反，它会在 micronaut 基础设施中出现 CircuitOpenException，从而导致请求中断。

有解决该问题的方法吗？

完整示例：https ://github.com/artfable/micronaut-test

更新：

创建了一个问题：https ://github.com/micronaut-projects/micronaut-rxjava3/issues/87

注释适用于来自 rxjava2 的 Single。因此，作为一种解决方法，使用将具有注释并返回 rxjava2 Single 的服务，在控制器中转换为 rxjava3 Single。

任何人都可以……</p>

1. 解释为什么下面的代码会无限期地重试，一旦retryWhen被调用？
2. Random.nextBoolean() 更正代码以在返回时停止重试true？

我认为有 50% 的机会retryWhen因为Random.nextBoolean(). 但是，一旦调用它，它就会进入无限循环。

输出：

我正在尝试查找有关 RxJava 和 RxFirebase 的任何视频或课程，但我发现的只是无数重复相同内容的视频，例如介绍。

有没有关于 rxAndroid 和 RxJava 的一些高级课程，尤其是关于 RxFirebase 的课程？

tnx

例如，假设我有一个 WebFilter，它写了一些 Context

在下游，我的控制器执行此操作

以上所有工作正常。

如果我想从控制器方法返回一个 Single 怎么办？我尝试使用RxJava3Adapter.monoToSingle()，但它破坏了反应器链。

我的猜测是，由于我没有返回 Mono，因此 RxJava3Adapter 内没有任何内容订阅此 contextMono。这是正确的解释吗？

有没有办法在传入 Context 时返回 Single ？

我在我的项目中使用 RxJava3，但我无法编写请求，我已经绞尽脑汁好几个小时了。

我有 List<Stream> 并且有一个通过 Stream 返回 Single<List<Topic>> 的函数，我想得到一个 Single<Map<Stream, List<Topic>>>，

我正在尝试使用 RxJava 并Single<Long>在成功插入房间数据库时返回 a，但编译时出现以下错误：

我所有的 Dao 类都扩展了这个接口：

更新

问题是，当我只有 1 个 insert 方法时，它可以工作，但是当我有 2 个或更多（如您所见，例如插入 a List<T>）时，它不起作用......

还有我的 build.gradle：

使用背压时如何在缓冲区中打印元素：

输出：
得到 1
Dropped.. :21
Dropped.. :22
Dropped.. :23
Dropped.. :24
Dropped.. :25
。
.
.

我想
在缓冲区中 有 1 个
元素：2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20
Dropped.. :21
.
.
.

我不知道这是否可能。请帮助我是反应式编程的新手
谢谢

可观察合约

Observables 必须串行（而不是并行）向观察者发出通知。他们可能会从不同的线程发出这些通知，但通知之间必须有正式的先发生关系。

当它说“happens-before”时，是否意味着上一个 onNext 通知的所有效果（例如更改 Observer.onNext() 方法中的共享状态）对于下一个 onNext 通知将完全可见，就像发生一样-Java 内存模型中的保证之前？

阅读 SerializedObserver（RxJava 版本 3.0.11）的源代码后，我发现在同步代码块中没有调用下游.onNext(t) 方法。那么，我可以说答案不是吗？

我有 Java TCP 客户端套接字读取 InputStream 并通过 RxJava PublishSubject 将数据包分发到应用程序的各个部分。这行得通。

有时我也会写信给 OutputStream。命令被转换为单个数据包（byte[]）并推送到流中。为此，我使用

现在我想执行

以符合以下条件的方式

1. 虽然源数据包是同时从多个位置（使用不同的命令）创建的，但对每个数据包执行上述操作，延迟为 50 毫秒。理想情况下，将数据包排队并延迟执行。

有没有办法使用 RxJava 来实现这一点。提前致谢！

我正在使用 RxJava3，并且我有以下代码设置，我想在中间发出一个项目，在第一个和第二个 flowable 之间。有没有办法做到这一点？

我想这样做的原因是因为在firstFlowable初始化之后有很长一段时间直到secondFlowable初始化，我想用一条消息通知 UI 操作已经开始，我正在等待来自secondFlowable.

我尝试使用startWithItem，但它在开始时初始化了我的整个链，但我只想在firstFlowable产生它的第一个值之后发出。