From eeb1dc14b36a4b2a63f9a1789ee8e12c334b2478 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= <kjetil.orbekk@gmail.com>
Date: Tue, 10 Apr 2012 15:18:41 +0200
Subject: Always run done() in protobuf services.

---
 same/src/main/java/com/orbekk/same/Client.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/same/src/main/java/com/orbekk/same/Client.java b/same/src/main/java/com/orbekk/same/Client.java
index 704dc8e..bd13576 100644
--- a/same/src/main/java/com/orbekk/same/Client.java
+++ b/same/src/main/java/com/orbekk/same/Client.java
@@ -113,6 +113,7 @@ public class Client {
                         new State.Component(request.getId(), request.getRevision(),
                                 request.getData()));
             }
+            done.run(Empty.getDefaultInstance());
         }
 
         @Override public void masterTakeover(RpcController controller,
@@ -129,6 +130,7 @@ public class Client {
             Client.this.masterUrl = request.getMasterUrl();
             Client.this.masterId = request.getMasterId();
             connectionState = ConnectionState.STABLE;
+            done.run(Empty.getDefaultInstance());
         }
 
         @Override public void masterDown(RpcController controller, MasterState request,
@@ -141,6 +143,7 @@ public class Client {
             logger.warn("Master down.");
             connectionState = ConnectionState.UNSTABLE;
             tryBecomeMaster(request.getMasterId());
+            done.run(Empty.getDefaultInstance());
         }
     };
     
-- 
cgit v1.2.3