设为首页 加入收藏

TOP

FunDA(7)- Reactive Streams to fs2 Pull Streams(三)
2017-10-09 14:30:09 】 浏览:5836
Tags:FunDA Reactive Streams fs2 Pull
cFuture pipe.unNoneTerminate(q.dequeue) } def log[A](prompt: String): Pipe[Task,A,A]
= _.eva lMap {row => Task.delay{ println(s"$prompt> $row"); row }} fs2Stream.through(log("")).run.unsafeRun }

 

 

 

 

 

 

 

 

 

 

 

 

首页 上一页 1 2 3 下一页 尾页 3/3/3
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇FunDA(6)- Reactive Streams:.. 下一篇FunDA(8)- Static Source:保..

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目