Merge pull request #443 from ringo/native-promise

Adapt to Rhino's NativePromise

src/org/ringojs/engine/RingoGlobal.java

@@ -217,7 +217,9 @@ public static Object spawn(Context cx, Scriptable thisObj,
             public Object call() {
                 return cxfactory.call(new ContextAction<Object>() {
                     public Object run(Context cx) {
-                        return function.call(cx, scope, scope, fnArgs);
+                        Object result = function.call(cx, scope, scope, fnArgs);
+                        cx.processMicrotasks();
+                        return result;
                     }
                 });
             }

src/org/ringojs/engine/RingoWorker.java

@@ -126,6 +126,7 @@ public Object invoke(Object module, Object function, Object... args)
             }
         } finally {
             releaseWorker(previous);
+            cx.processMicrotasks();
             Context.exit();
         }
     }

test/all.js

@@ -22,6 +22,7 @@ exports.testBinary         = require('./binary/all');
 exports.testRepository     = require('./repository/all');
 exports.testIo             = require('./io_test');
 exports.testModules        = require('./modules/all');
+exports.testRhino          = require("./rhino/all");
 
 // Also include integration tests
 exports.testIntegration    = require('./integration-tests/all');

test/rhino/all.js

@@ -0,0 +1,4 @@
+exports.testArrowFunctions = require("./arrow_functions");
+exports.testConstStatement = require("./const_statement");
+exports.testLetStatement = require("./let_statement");
+exports.testPromise = require("./promise_test");

test/rhino/promise_test.js

@@ -0,0 +1,22 @@
+const assert = require("assert");
+const {Semaphore} = require("ringo/concurrent");
+
+exports.testResolve = () => {
+    const semaphore = new Semaphore();
+    let expected = false;
+    spawn(() => {
+        return new Promise(resolve => {
+            java.lang.Thread.sleep(100);
+            resolve(true);
+        }).then(value => {
+            expected = value;
+            semaphore.signal();
+        });
+    });
+    semaphore.tryWait(150);
+    assert.isTrue(expected);
+};
+
+if (require.main === module) {
+    require("system").exit(require("test").run(module.id));
+}