📌 Nodepp | Stable Release | V1.3.0 📌

Author: EDBCREPO

examples/17-task-resolver.cpp

@@ -0,0 +1,29 @@
+#include <nodepp/nodepp.h>
+#include <nodepp/promise.h>
+
+using namespace nodepp;
+
+void onMain() {
+
+    ptr_t<uint> value = new uint(0);
+
+    process::resolve( coroutine::add( COROUTINE(){
+    coBegin
+
+        coDelay( 1000 );
+        *value = 10;
+
+    coFinish
+    }))
+
+    .then([=]( null_t ){
+        console::log( *value );
+    })
+
+    .fail([=]( except_t err ){
+        console::error( err.what() );
+    });
+
+    console::log( "Hello!" );
+
+}

include/nodepp/coroutine.h

@@ -60,10 +60,10 @@ namespace nodepp { class coroutine_t {
 
     /*─······································································─*/
 
-    coEmit() const noexcept { return next(); }
+    coEmit() const { return next(); }
 
-    int next() const noexcept {
-        if( !obj->alive ){ return -1; }
+    int next() const {
+        if ( !obj->alive ){ return -1; }
         return obj->callback( obj->state, obj->time );
     }
 

include/nodepp/promise.h

@@ -208,6 +208,29 @@ namespace nodepp { template< class T, class V > class promise_t {
 
 /*────────────────────────────────────────────────────────────────────────────*/
 
+namespace nodepp { namespace promise { 
+
+    template< class T, class... V >
+    promise_t<null_t,except_t> resolve( T cb, const V&... args ) {
+    return promise_t<null_t,except_t>([=]( res_t<null_t> res, rej_t<except_t> rej ){
+
+        process::add( coroutine::add( COROUTINE(){
+        coBegin try {
+
+            while( cb( args... )>=0 ){ return 1; }
+            res( nullptr );
+
+        } catch( except_t err ) {
+            rej( err );
+        } coFinish
+        } ));
+
+    }); }
+
+}}
+
+/*────────────────────────────────────────────────────────────────────────────*/
+
 namespace nodepp { namespace promise {
 
     template< class V >

test/task.cpp

@@ -1,4 +1,5 @@
 #include <nodepp/nodepp.h>
+#include <nodepp/promise.h>
 #include <nodepp/test.h>
 
 using namespace nodepp;
@@ -48,6 +49,24 @@ namespace TEST { namespace TASK {
             } catch ( ... ) { TEST_FAIL(); }
         });
 
+        TEST_ADD( test, "TEST 3 | task resolver testing", [](){
+            try { ptr_t<int> x = new int(0); 
+                  ptr_t<int> y = new int(3);
+
+                promise::resolve( coroutine::add( COROUTINE(){
+                coBegin
+
+                    while( *y>0 ){ *x += 10; *y-=1; coNext; }
+                    
+                coFinish
+                })).emit();
+                
+             while( *y!=0 ){ process::next(); }
+                if( *x != 30 ){ TEST_FAIL(); }
+                              TEST_DONE();
+            } catch ( ... ) { TEST_FAIL(); }
+        });
+
         test.onClose.once([=](){
             console::log("\nRESULT | total:", *totl, "| passed:", *done, "| error:", *err, "| skipped:", *skp );
         });