小编Atl*_*tle的帖子

Hazelcast Jet和Apache Flink有什么区别

更具体地说,Hazelcast Jet解决了Flink无法解决的问题(同样好),反之亦然?

apache-flink hazelcast-jet

9
推荐指数
1
解决办法
1409
查看次数

使用Scalaz流,如何将A => Task [B]转换为Process1 [A,B]

我正在将一个http请求编码为远程服务器作为一个函数,它接受一个id并产生一个Task [JValue].

我想将该函数转换为Process1,以简化我的程序(通过简化,我的意思是尽可能使用Processes作为构建块)

我想转换这个功能

    reqDoc(id:A):Task[B]
Run Code Online (Sandbox Code Playgroud)

(其中A是Id的类型,B是响应的类型)

    reqDoc:Process1[A,B]
Run Code Online (Sandbox Code Playgroud)

scala scalaz scalaz-stream

2
推荐指数
1
解决办法
383
查看次数