问题标签 [cyclops-react]

我正在使用simple-react。

在里面LazyFutureStream我想坚持实体。

这个对吗 ？有什么办法可以跳过每个线程的会话工厂创建。

同样在上面我只想分叉而不是加入。可以吗？

使用 cyclops-react 1.0.0-RC3，我尝试使用批处理重新创建 cyclops-react流用户指南中的示例。我发现其中缺少一些方法ReactiveSeq，包括batchBySize和windowByTime。

我确实找到了这些方法StreamUtils并且它们按预期工作，但看起来不像用户指南中的示例那么光滑......

从用户指南...

我能得到什么工作......

testBatchingSlidingWindowing您可以在方法测试类StreamsTest.java中的工作 JUnit 中查看我的代码

我应该期望找到batchBySizeand windowByTimeonReactiveSeq还是使用StreamUtils适当的方式？

我开始将 cyclops-react 与异步重试一起使用。我还是有点迷茫。

我正在使用 SimpleReact 并模拟来自服务器的超时，但我从未收到类似这样的超时：

那里缺少什么？

给定一些使用流处理大量项目的代码，检测日志记录和性能/分析的各个步骤的最佳方法是什么？

实际示例：

记录进度很重要，因此我可以在另一个线程中触发更新用户界面的进度事件。

跟踪此流中过滤和映射步骤的性能特征是可取的，以查看可以在哪些地方进行优化以加快速度。

我看到三个选项：

1. 将日志记录/分析代码放在每个函数中
2. peek在每个步骤中使用而不实际使用该值
3. 某种基于注释或 AOP 的解决方案（不知道是什么）

哪个是最好的？关于#3 的样子有什么想法吗？还有其他解决方案吗？

我正在尝试使用 cyclops-react 根据大小和时间对队列中的元素进行批处理，因此当没有元素时它不会阻塞

也许功能不是我所期望的，或者我做错了什么

完整的代码（Groovy）是这样的，生产者在另一个线程中：

输出是：

但我期待每批中有一个元素，因为提供的元素之间的延迟是 10 秒，但批处理是每半秒

我还尝试了异步流（Groovy 代码）：

同样，它仅每 2 秒批处理一次，有时每批处理等待两个元素，即使批处理中的超时为半秒：

我对非未来非惰性流进行了第三次实验，这次它奏效了。

结果：

当您使用未来的流时，为什么批处理的行为似乎是错误的？

在 Cyclops React “Try with Resources”块中，我想将 an 映射IOException到自定义异常类型。我也用 Javaslang 尝试过这个，并且似乎不太灵活，因为它对待所有异常都是一样的。

代码示例：

这可以以更优雅的方式完成吗？还是没有任何意义，最好返回Try<String, IOException>？

免责声明：我是一般使用 Cyclops React 库和函数式编程的新手，所以我可能对概念有严重的误解。

是否可以使用 cyclops-react 库同时拥有订阅者？例如，如果运行以下代码：

我得到以下结果：

我在订阅者流中得到重复的值。提前感谢您的帮助。