Akka如何连接源,流和接收器

2020年3月12日 35点热度 0条评论

我创建了一个源,一个流和一个接收器

源是整数源

流将整数传输到字符串

然后接收器将写入文件

但是我不知道如何将所有这些连接在一起以获得可运行的图

 public static void main(String[] args) {
        ActorSystem system = ActorSystem.create();
        Materializer materializer = ActorMaterializer.create(system);
        Source<Integer, NotUsed> source = Source.range(0, 100);
        Flow<Integer, ByteString, NotUsed> flow = Flow.fromFunction((i) -> {
            return ByteString.fromString(i.toString());
        });
        Sink<ByteString, CompletionStage<IOResult>> sink = FileIO.toPath(Paths.get("love.txt"));
    }

解决方案如下:

我将重点放在您的“可运行图形”上。
请注意https://doc.akka.io/docs/akka/current/stream/stream-graphs.html#constructing-graphs,并在左侧使用Java作为您的编程语言,以获取正确的代码示例。
此页面上是可运行的图形示例代码,该代码应有助于您将流式元素连接在一起。