Rxjava超时操作符，只考虑从特定点发出的项
示例：
Observable.timer(1, TimeUnit.SECONDS)
.flatMap { performNetworkRequest() }
.timeout(1, TimeUnit.HOUR)
所以我的想法是在一个小时后结束这个计时器，没有服务器响应。但是timeout运算符不是这样工作的，因为它是在计时器observable每分钟发送一个新项时重置的。
共有1个答案
医生是这么说的
如果Observable在指定的时间跨度内未能发出任何项，Timeout运算符允许您用onError终止中止该Observable。
-在这里，你每分钟都在发射物品，所以它不像你想要的那样工作。
-
这节包含一些杂项：‘做'与'不做'。 不要通过宏替换来改变语法。这将导致程序对于所有人都是难以理解的，除了那个肇事者。 不要在需要离散值的地方使用浮点变量。使用一个浮点数作为循环计数器无疑是搬起石头砸自己的脚。总是用<=或>=测试浮点数，对它们永远不要 用精确比较(==或!=)。 编译器也有bug。常见且高发的问题包括结构体赋值和位字段。你无法泛泛的预测一个编译器都有哪些bug。但你可以在程序中避
-
主要内容：RxJava 过滤操作符 介绍,RxJava 过滤操作符 示例RxJava 过滤操作符 介绍 以下是用于从 Observable 中选择性地发送信息的运算符。 运算符 描述 Debounce 仅在发生超时时才发送项目而不发送另一个项目。 Distinct 只发送独特的物品。 ElementAt 仅发出由 Observable 发出的 n 个索引处的项目。 Filter 只发出那些通过给定谓词函数的项目。 First 发出通过给定条件的第一个项目或第一个项目。
-
主要内容：RxJava 转换操作符 介绍,RxJava 转换操作符 示例RxJava 转换操作符 介绍 以下是用于转换从 Observable 发出的信息的运算符。 运算符 描述 Buffer 定期将 Observable 中的项目收集到包中，然后发出包而不是项目。 FlatMap 用于嵌套的 observable。将项目转换为 Observable。然后将项目展平为单个 Observable。 GroupBy 将一个 Observable 分成按键组织的一组 Obs
-
主要内容：RxJava 创建操作符 介绍,RxJava 创建操作符 示例RxJava 创建操作符 介绍 以下是用于创建 Observable 的运算符。 运算符 描述 Create 从头开始创建一个 Observable 并允许以编程方式调用观察者方法。 Defer 在观察者订阅之前不要创建 Observable。为每个观察者创建一个新的 observable。 Empty/Never/Throw 创建一个行为受限的 Observable。 From 将对象/数据结构
-
我的问题是，我的Box2D身体有另一个位置，而不是我想为该身体渲染的LibGDX精灵。在我的渲染循环中，对于每个实体，我将其精灵的位置设置为实体的位置，然后渲染它。创建圆以外的Box2D形状时，Box2D不会将其从原点移动，LibGDX精灵也不会移动。如果我现在移动或设置身体的位置，我的精灵将始终跟随它。但不幸的是，这在圆形图形中是不可能的：因为LibGDX的Sprite#设置位置没有考虑Spri
-
你能告诉我一种从Java执行进程而不管底层操作系统的方法吗？例如。 上面的行在Windows环境中执行Maven，但我如何在任何操作系统中运行上面的命令？ 如果我没有在启动时添加，那么我就无法在windows环境中运行，错误显示尽管maven主页设置正确。