handle_client_close.java

getContext().watch(_eventSourceActor);

@Override
public Receive createReceive() {
  return receiveBuilder()
    .match(
      Terminated.class,
      terminated -> {
        if (terminated.getActor().equals(_eventSourceActor)) {
            getContext().stop(self());
        }
      }
    )
    .build();
}