debugging - 如何调试 akka 流？

Question

当我在方法 processLine 中的某处放置断点时，调试器不会在该行停止。它的执行就像没有任何断点一样。调试akka流的流程是否有所不同，我该如何解决这个问题？

val stream = source.
                 map( csvLine => A.processLine(csvLine)).
                 runWith(Sink)

Answer 1

我对ScalaIDE也有类似的问题。

我的解决方案通常是将我的“业务逻辑”与任何 akka 依赖项隔离开来：

//no akka imports required

case class Tweet(val author : String, val body : String)

def validAuthor(author : String) : Boolean = {
  author.trim().size > 0 && !author.equalsIgnoreCase("jk_rowling") //breakpoint works here
}

然后我的异步代码变成了对 buz 逻辑的简单调用：

import akka.stream.scaladsl.{Source, Sink}

val source : Source[Tweet,_] = ???

val flow = source.filter(validAuthor)
                 .runWith(Sink foreach println)

然后 IDE 遵循 buz 逻辑中的断点，例如在validAuthor.