如何使用Java在Akka流中加入流

如何解决如何使用Java在Akka流中加入流

我是Akka Streams的新手。如何使用akka创建以下调用序列：

读取文件->处理文件的行->通过tcp调用远程服务器->接收并处理响应

我不明白如何以这种方式连接从文件读取的行：

final Source<String,NotUsed> lines =
       akka.stream.alpakka.file.javadsl.FileTailSource.createLines(fs.getPath(FILE_NAME),maxLinesize,pollingInterval,"\n",Charset.forName("utf8"));

和

final Flow<ByteString,ByteString,CompletionStage<Tcp.OutgoingConnection>> connection =
                Tcp.get(system).outgoingConnection("127.0.0.1",8888);

CompletionStage<Tcp.OutgoingConnection> connectionCS =  connection.join(repl).run(system);