| Index: mojo/public/java/bindings/src/org/chromium/mojo/bindings/Connector.java | 
| diff --git a/mojo/public/java/bindings/src/org/chromium/mojo/bindings/Connector.java b/mojo/public/java/bindings/src/org/chromium/mojo/bindings/Connector.java | 
| index 17cc7ed9fe27e3d3d540a5edc792246a60f076ce..cc9f12ceb8d75134af4af02533ef5b8c735d7792 100644 | 
| --- a/mojo/public/java/bindings/src/org/chromium/mojo/bindings/Connector.java | 
| +++ b/mojo/public/java/bindings/src/org/chromium/mojo/bindings/Connector.java | 
| @@ -115,7 +115,11 @@ public class Connector implements MessageReceiver, HandleOwner<MessagePipeHandle | 
| @Override | 
| public MessagePipeHandle passHandle() { | 
| cancelIfActive(); | 
| -        return mMessagePipeHandle.pass(); | 
| +        MessagePipeHandle handle = mMessagePipeHandle.pass(); | 
| +        if (mIncomingMessageReceiver != null) { | 
| +            mIncomingMessageReceiver.close(); | 
| +        } | 
| +        return handle; | 
| } | 
|  | 
| /** | 
| @@ -125,6 +129,9 @@ public class Connector implements MessageReceiver, HandleOwner<MessagePipeHandle | 
| public void close() { | 
| cancelIfActive(); | 
| mMessagePipeHandle.close(); | 
| +        if (mIncomingMessageReceiver != null) { | 
| +            mIncomingMessageReceiver.close(); | 
| +        } | 
| } | 
|  | 
| private class AsyncWaiterCallback implements AsyncWaiter.Callback { | 
|  |