我有一个功能f
和一个频道c
def f(i: Int) = Task.now(i + 1)
val c = channel.lift(f)
我想将函数连续应用f
任意次数(或无限期)到先前计算的输出。我提供初始值。
我可以定义一个流程p
val p = Process.emit(1).through(c)
但这只会执行一次。
我怎样才能继续应用c
到最后一次计算的输出?
我有一个功能f
和一个频道c
def f(i: Int) = Task.now(i + 1)
val c = channel.lift(f)
我想将函数连续应用f
任意次数(或无限期)到先前计算的输出。我提供初始值。
我可以定义一个流程p
val p = Process.emit(1).through(c)
但这只会执行一次。
我怎样才能继续应用c
到最后一次计算的输出?