Akka Stream callbacks

Question

Je suis nouveau chez Akka Streams et j'ai une question.

j'ai donc un client (code source de documentation officielle ci-dessous) qui peut gérer et traiter les données à partir du serveur .

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); 

Comment puis-je ajouter des méthodes de rappel (onComplete(), onError())?

Answer 1

Jetez un oeil à watchTermination combinateur qui rendra le flux matérialisé un avenir, qui sera achevé ou échoué selon que le flux se termine ou des erreurs.