Observable.Generate 在 RxJava 中?
.NET Reactive Extensions 有一个使用 corecursion 生成序列的简洁方法，称为 Observable.Generate. RxJava 中是否有允许通过 corecursion 生成数据的类似方法?如果不是，是否可以基于现有方法实现? 解决方案 这不是完全匹配，但我们有 SyncOnSubscribe(和 AsyncOnSubscriber)可以生成值
..
corecursion相关内容
如何在严格评估的设置中编码corecursion/codata?
Corecursion意味着在每次迭代中调用大于或等于以前的数据的数据. Corecursion在协数据上工作，协数据是递归定义的值.不幸的是，在严格评估的语言中无法进行值递归.不过，我们可以处理明显的重击: const Defer = thunk => ({get runDefer() {return thunk()}}) const app = f => x => f(x);
..
使用变形的列表过滤器
我使用了recursion-schemes黑客库中的变形来实现了损坏的filter函数: import Data.Functor.Foldable xfilter :: (a -> Bool) -> [a] -> [a] xfilter f = ana $ project . phi f phi :: (a -> Bool) -> [a] -> [a] phi f (h : t) | n
..
从链式任务可观测
我试图创建一个可观察的，其中每个项目通过异步任务产生的。下一项目应该经由在previous项目（共递归）的结果一个异步呼叫来制造。在“生成”的说法，这将是这个样子 - 除了生成不支持异步（也不支持在初始状态委托 变种OB = Observable.Generate（ 异步（）=＆GT;等待ProduceFirst（）//任务＆LT; T＆GT; ProduceFirst（） preV
..