example of exception handling

src/main/java/chat/ChatServiceImpl.java

@@ -48,8 +48,19 @@ public class ChatServiceImpl extends ChatServiceImplBase {
                     //we exclude the one which is sending the message
                     if(!observer.equals(responseObserver))
                         //we simply forward the message
-                        observer.onNext(ChatMessage.newBuilder().setMessage(message).setFrom(from).build());
+                        try {
 
+                            observer.onNext(ChatMessage.newBuilder().setMessage(message).setFrom(from).build());
+
+                        }
+                        catch(io.grpc.StatusRuntimeException e){
+                            //peer no longer available
+                            synchronized (observers){
+
+                                observers.remove(responseObserver);
+
+                            }
+                        }
                 }
 
             }