Akka Stream回調

Question

我是Akka Streams的新手，我有一個問題。

所以我可以從服務器操作和處理數據的一些客戶（從下面的官方文檔的源代碼）。

private static final ActorSystem system = ActorSystem.create("Client"); 
private static final Materializer materializer = ActorMaterializer.create(system); 

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

final Flow<ByteString, ByteString, NotUsed> repl = 
    Flow.of(ByteString.class) 
     .map(ByteString::utf8String) 
     .map(text -> { 
      System.out.println("Server message ->: " + text); 
      return ByteString.fromString(text); 
     }); 

connection.join(repl).run(materializer); 

如何添加回調方法（onComplete()，onError()）？

Answer 1

看看watchTermination combinator，它會使流實現一個Future，根據流是否完成或錯誤將完成或失敗。