【发布时间】:2017-04-25 15:17:38
【问题描述】:
我正在试验akka,并且(按照文档),我有以下代码:
Source<String, NotUsed> words =
Source.from(Arrays.asList("hello", "hi"));
Timeout askTimeout = Timeout.apply(5, TimeUnit.SECONDS);
words
.mapAsync(5, elem -> ask(ref, elem, askTimeout))
.map(elem -> (String) elem)
// continue processing of the replies from the actor
.map(elem -> elem.toLowerCase())
.runWith(Sink.ignore(), materializer);
但我找不到“导入静态”指令来使“询问方法”工作。 我得到了:
无法解决方法询问
我做错了什么?我正在使用 akka v 2.4(使用 Java,没有 Scala)并逐步遵循文档: http://doc.akka.io/docs/akka/2.4/java/stream/stream-integrations.html
谢谢。
【问题讨论】:
标签: java akka akka-stream