Index: mojo/public/java/bindings/src/org/chromium/mojo/bindings/RouterImpl.java |
diff --git a/mojo/public/java/bindings/src/org/chromium/mojo/bindings/RouterImpl.java b/mojo/public/java/bindings/src/org/chromium/mojo/bindings/RouterImpl.java |
index 4633a92a255cfc0ad40b030cf529b3c0f6a6d140..25337fbaced02dfea554d252a2ae7eabe6ff3a5d 100644 |
--- a/mojo/public/java/bindings/src/org/chromium/mojo/bindings/RouterImpl.java |
+++ b/mojo/public/java/bindings/src/org/chromium/mojo/bindings/RouterImpl.java |
@@ -28,6 +28,14 @@ public class RouterImpl implements Router { |
return handleIncomingMessage(message); |
} |
+ /** |
+ * @see org.chromium.mojo.bindings.MessageReceiver#close() |
+ */ |
+ @Override |
+ public void close() { |
+ handleConnectorClose(); |
+ } |
+ |
} |
/** |
@@ -175,4 +183,10 @@ public class RouterImpl implements Router { |
} |
return false; |
} |
+ |
+ private void handleConnectorClose() { |
+ if (mIncomingMessageReceiver != null) { |
+ mIncomingMessageReceiver.close(); |
+ } |
+ } |
} |