Index: mojo/public/js/connector.js |
diff --git a/mojo/public/js/bindings/connector.js b/mojo/public/js/connector.js |
similarity index 94% |
rename from mojo/public/js/bindings/connector.js |
rename to mojo/public/js/connector.js |
index 495896d3b2a59200c28b86c3c4163a891035f523..badd12a9f3e9811eaeabd373c28f5e921d339ee9 100644 |
--- a/mojo/public/js/bindings/connector.js |
+++ b/mojo/public/js/connector.js |
@@ -2,11 +2,11 @@ |
// Use of this source code is governed by a BSD-style license that can be |
// found in the LICENSE file. |
-define("mojo/public/js/bindings/connector", [ |
- "mojo/public/js/bindings/buffer", |
- "mojo/public/js/bindings/codec", |
- "mojo/public/js/bindings/core", |
- "mojo/public/js/bindings/support", |
+define("mojo/public/js/connector", [ |
+ "mojo/public/js/buffer", |
+ "mojo/public/js/codec", |
+ "mojo/public/js/core", |
+ "mojo/public/js/support", |
], function(buffer, codec, core, support) { |
function Connector(handle) { |
@@ -86,6 +86,8 @@ define("mojo/public/js/bindings/connector", [ |
for (;;) { |
var read = core.readMessage(this.handle_, |
core.READ_MESSAGE_FLAG_NONE); |
+ if (this.handle_ == null) // The connector has been closed. |
+ return; |
if (read.result == core.RESULT_SHOULD_WAIT) { |
this.waitToReadMore_(); |
return; |