【问题标题】:Cannot resolve method ask - Akka Streaming with Java无法解决方法询问 - Akka Streaming with Java
【发布时间】: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


    【解决方案1】:

    ask 指代问模式

    您可以使用 import static akka.pattern.Patterns.ask 从 java 中使用它

    【讨论】:

      【解决方案2】:

      这对我有用:import akka.pattern.ask

      【讨论】:

        猜你喜欢
        • 2018-10-26
        • 2021-05-07
        • 2014-04-12
        • 2017-04-20
        • 2012-10-11
        • 1970-01-01
        • 2018-06-01
        • 1970-01-01
        • 1970-01-01
        相关资源
        最近更新 更多