设为首页 加入收藏

TOP

ScalaPB（3）： gRPC streaming(三)
2019-08-15 00:11:45 【大 中 小】 浏览:302次
Tags：ScalaPB gRPC streaming
println(s"ON_ERROR: $t") def onCompleted(): Unit = println("ON_COMPLETED") def onNext(value: SumResponse): Unit = println(s"ON_NEXT: Current sum: ${value.currentResult}") } //get request container val requestObserver = client.addInter(responseObserver) scheduler.scheduleWithFixedDelay(0.seconds, 1.seconds) { val toBeAdded = Random.nextInt(11) println(s"Adding number: $toBeAdded") requestObserver.onNext(SumRequest(toBeAdded)) } scala.io.StdIn.readLine() } }

 
首页 上一页 1 2 3 4 5 下一页 尾页 3/5/5
【大 中 小】【打印】 【繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部】
上一篇：ScalaPB（5）：用akka-stream实现.. 下一篇：ScalaPB（2）： 在scala中用gRPC..

最新文章

Scala-面向对象编程
Scala-变量与数据类型
ctfshow--web入门--文件上传
Scala的基本使用
Scala集合

热门文章

Scalaz（8）－ typeclass：Monoid a..
Scalaz（41）－ Free ：IO Monad－F..
FunDA（15）－ 示范：任务并行运算 ..
Akka（10）： 分布式运算：集群-Clu..
Scalaz（52）－ scalaz-stream: 并..

Hot 文章

Scalaz（8）－ typeclass：Monoid a..
Scalaz（41）－ Free ：IO Monad－F..
FunDA（15）－ 示范：任务并行运算 ..
Akka（10）： 分布式运算：集群-Clu..
Scalaz（52）－ scalaz-stream: 并..

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目