1 files changed, 70 insertions, 0 deletions
diff --git a/js/test/Ice/operations/ClientBidir.js b/js/test/Ice/operations/ClientBidir.js
new file mode 100644
index 00000000000..0ed0a1c14c8
--- /dev/null
+++ b/js/test/Ice/operations/ClientBidir.js
@@ -0,0 +1,70 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2016 ZeroC, Inc. All rights reserved.
+//
+// This copy of Ice is licensed to you under the terms described in the
+// ICE_LICENSE file included in this distribution.
+//
+// **********************************************************************
+
+(function(module, require, exports)
+{
+    var Ice = require("ice").Ice;
+    var Test = require("Test").Test;
+    var MyDerivedClassI = require("MyDerivedClassI").MyDerivedClassI;
+    var AMDMyDerivedClassI = require("AMDMyDerivedClassI").AMDMyDerivedClassI;
+    var Client = require("Client.js");
+
+    var Promise = Ice.Promise;
+
+    var allTests = function(out, communicator, amd)
+    {
+        return communicator.createObjectAdapter("").then(adapter =>
+            {
+                if(amd)
+                {
+                    adapter.add(new AMDMyDerivedClassI(), Ice.stringToIdentity("test"));
+                }
+                else
+                {
+                    adapter.add(new MyDerivedClassI(), Ice.stringToIdentity("test"));
+                }
+                var base = communicator.stringToProxy("test:default -p 12010");
+                return base.ice_getConnection().then(conn =>
+                    {
+                        conn.setAdapter(adapter);
+                        return Client.__clientAllTests__(out, communicator, Test, true);
+                    });
+            });
+    };
+
+    var run = function(out, id)
+    {
+        id.properties.setProperty("Ice.BatchAutoFlushSize", "100");
+        var communicator = Ice.initialize(id);
+        return Promise.try(() =>
+            {
+                out.writeLine("testing bidir callbacks with synchronous dispatch...");
+                return allTests(out, communicator, false);
+            }
+        ).then(() => communicator.destroy()
+        ).then(() =>
+            {
+                communicator = Ice.initialize(id);
+                out.writeLine("testing bidir callbacks with asynchronous dispatch...");
+                return allTests(out, communicator, true);
+            }
+        ).then(() => communicator.destroy()
+        ).then(() =>
+            {
+                communicator = Ice.initialize(id);
+                return Test.EchoPrx.checkedCast(communicator.stringToProxy("__echo:default -p 12010"));
+            }
+        ).then(prx => prx.shutdown()
+        ).finally(() => communicator.destroy());
+    };
+    exports.__testBidir__ = run;
+}
+(typeof(global) !== "undefined" && typeof(global.process) !== "undefined" ? module : undefined,
+ typeof(global) !== "undefined" && typeof(global.process) !== "undefined" ? require : this.Ice.__require,
+ typeof(global) !== "undefined" && typeof(global.process) !== "undefined" ? exports : this));