akgupta · January 31, 2020 23:42
diff --git a/handle_client_close.java b/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();
 }
	getContext().watch(_eventSourceActor);

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