1 files changed, 120 insertions, 0 deletions
diff --git a/js/src/Ice/AsyncResult.js b/js/src/Ice/AsyncResult.js
new file mode 100644
index 00000000000..1f2d5f8c6b2
--- /dev/null
+++ b/js/src/Ice/AsyncResult.js
@@ -0,0 +1,120 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2014 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(global){
+    require("Ice/Class");
+    require("Ice/AsyncResultBase");
+    require("Ice/Debug");
+    require("Ice/Promise");
+    require("Ice/Protocol");
+    require("Ice/Exception");
+    require("Ice/BasicStream");
+
+    var Ice = global.Ice || {};
+
+    var AsyncResultBase = Ice.AsyncResultBase;
+    var Debug = Ice.Debug;
+    var Promise = Ice.Promise;
+    var Protocol = Ice.Protocol;
+    var UserException = Ice.UserException;
+    var BasicStream = Ice.BasicStream;
+
+    var AsyncResult = Ice.Class(AsyncResultBase, {
+        __init__: function(communicator, op, connection, proxy, adapter, completedFn, sentFn)
+        {
+            //
+            // AsyncResult can be constructed by a sub-type's prototype, in which case the
+            // arguments are undefined.
+            //
+            AsyncResultBase.call(this, communicator, op, connection, proxy, adapter);
+            if(communicator !== undefined)
+            {
+                this._completed = completedFn;
+                this._sent = sentFn;
+                this._is = null;
+                this._os = communicator !== null ?
+                    new BasicStream(this._instance, Protocol.currentProtocolEncoding, false) : null;
+                this._state = 0;
+                this._exception = null;
+            }
+        },
+        __os: function()
+        {
+            return this._os;
+        },
+        __is: function()
+        {
+            return this._is;
+        },
+        __startReadParams: function()
+        {
+            this._is.startReadEncaps();
+            return this._is;
+        },
+        __endReadParams: function()
+        {
+            this._is.endReadEncaps();
+        },
+        __readEmptyParams: function()
+        {
+            this._is.skipEmptyEncaps(null);
+        },
+        __readParamEncaps: function()
+        {
+            return this._is.readEncaps(null);
+        },
+        __throwUserException: function()
+        {
+            Debug.assert((this._state & AsyncResult.Done) !== 0);
+            if((this._state & AsyncResult.OK) === 0)
+            {
+                try
+                {
+                    this._is.startReadEncaps();
+                    this._is.throwException();
+                }
+                catch(ex)
+                {
+                    if(ex instanceof UserException)
+                    {
+                        this._is.endReadEncaps();
+                    }
+                    throw ex;
+                }
+            }
+        },
+        __exception: function(ex)
+        {
+            this._state |= AsyncResult.Done;
+            this._exception = ex;
+            this._os.resize(0);
+            this.fail(ex, this);
+        },
+        __response: function()
+        {
+            //
+            // Note: no need to change the state here, specializations are responsible for
+            // changing the state.
+            //
+
+            if(this.proxy !== null && this.proxy.ice_isTwoway())
+            {
+                Debug.assert(this._completed !== null);
+                this._completed(this);
+            }
+        }
+    });
+    
+    AsyncResult.OK = 0x1;
+    AsyncResult.Done = 0x2;
+    AsyncResult.Sent = 0x4;
+
+    Ice.AsyncResult = AsyncResult;
+    global.Ice = Ice;
+}(typeof (global) === "undefined" ? window : global));