nodepp V1.4.0_5

Author: EDBCREPO

.gitignore

@@ -1,4 +1,5 @@
 image.jpg
 main.exe
 build
-main
+main
+www

examples/0-isolated-module/main.cpp

@@ -0,0 +1,48 @@
+#include <nodepp/nodepp.h>
+#include <nodepp/worker.h>
+#include <nodepp/channel.h>
+#include <nodepp/encoder.h>
+
+using namespace nodepp;
+
+#include "module1.h"
+#include "module2.h"
+
+void onMain(){
+
+    pair_t<worker_t,channel_t<coroutine_t>> module2 = module_2_start();
+    pair_t<worker_t,channel_t<coroutine_t>> module1 = module_1_start();
+
+    module2.second.write( coroutine_t( COROUTINE(){
+    coBegin
+
+        while( true ){
+            console::log( "hello from module 2" );
+        coDelay(100); }
+
+    coFinish
+    }));
+
+    module1.second.write( coroutine_t( COROUTINE(){
+    coBegin
+
+        while( true ){
+            console::log( "hello from module 1" );
+        coDelay(300); }
+
+    coFinish
+    }));
+
+    process::add( coroutine::add( COROUTINE(){
+    coBegin
+
+        while( true ){
+            console::log( "<---------------->" );
+            console::log( "<2>", module2.first.is_closed() );
+            console::log( "<2>", module1.first.is_closed() );
+        coDelay(1000); }
+
+    coFinish
+    }));
+
+}

examples/0-isolated-module/module1.cpp

@@ -0,0 +1,7 @@
+#include <nodepp/nodepp.h>
+#include <nodepp/worker.h>
+#include <nodepp/channel.h>
+
+using namespace nodepp;
+
+pair_t<worker_t,channel_t<coroutine_t>> module_1_start();

examples/0-isolated-module/module1.h

@@ -0,0 +1,21 @@
+#ifndef MODULE_1
+#define MODULE_1
+
+pair_t<worker_t,channel_t<coroutine_t>> module_1_start(){
+
+     channel_t<coroutine_t> chn;
+
+     return { worker::add( coroutine::add( COROUTINE(){
+     coBegin
+
+          while( true ){
+          if   ( !chn.empty() ){
+          for  ( auto &x: chn.read() ){ process::add( x ); }}
+          if   ( process::size() == 0 ){ coDelay(1000); } process::next(); }
+
+     coFinish
+     }) ), chn };
+     
+}
+
+#endif

examples/0-isolated-module/module2.cpp

@@ -0,0 +1,7 @@
+#include <nodepp/nodepp.h>
+#include <nodepp/worker.h>
+#include <nodepp/channel.h>
+
+using namespace nodepp;
+
+pair_t<worker_t,channel_t<coroutine_t>> module_2_start();

examples/0-isolated-module/module2.h

@@ -0,0 +1,21 @@
+#ifndef MODULE_2
+#define MODULE_2
+
+pair_t<worker_t,channel_t<coroutine_t>> module_2_start(){
+
+     channel_t<coroutine_t> chn;
+
+     return { worker::add( coroutine::add( COROUTINE(){
+     coBegin
+
+          while( true ){
+          if   ( !chn.empty() ){
+          for  ( auto &x: chn.read() ){ process::add( x ); }}
+          if   ( process::size() == 0 ){ coDelay(1000); } process::next(); }
+
+     coFinish
+     }) ), chn };
+     
+}
+
+#endif

examples/0-stl_interop.cpp

@@ -0,0 +1,33 @@
+#include <nodepp/nodepp.h>
+#include <nodepp/event.h>
+
+#include <string>
+#include <queue>
+#include <vector>
+#include <functional>
+
+using namespace nodepp;
+
+void onMain(){
+
+    ptr_t<int> ptr ( 0UL, 10 ); // as value
+//  ptr_t<int> ptr ( 1UL, 10 ); // as buffer
+
+    std::function<void(int)> clb ([=]( int value ){
+        console::log( value, *ptr );
+    });
+
+    event_t<int> ev; ev.once( clb );
+    ev.emit( 100 );
+
+    std::string str = "hello world";
+    console::log( ">>", str );
+
+    std::vector<int> arr ({ 10, 20, 30, 40, 50 });
+    console::log( ">>", array_t<int>( arr ).join() );
+
+    std::queue<int> st ({ 10, 20, 30, 40 });
+    queue_t<int> que ( st );
+    que.map([=]( int value ){ console::log( "<>", value ); });
+
+}

examples/15-TCP.cpp

@@ -1,4 +1,5 @@
 #include <nodepp/nodepp.h>
+#include <nodepp/worker.h>
 #include <nodepp/tcp.h>
 #include <nodepp/fs.h>
 
@@ -74,9 +75,12 @@ void client(){
 
 void onMain() {
 
-    if( process::env::get("mode")=="client" ) 
-      { client(); } else { server(); }
+    worker::add( coroutine::add( COROUTINE(){
+    coBegin /*--*/ ; server();
+    process::wait(); coFinish }));
 
-}
+    worker::add( coroutine::add( COROUTINE(){
+    coBegin /*--*/ ; client();
+    process::wait(); coFinish }));
 
-// g++ -o main main.cpp -I./include ; ./main ?mode=client
+}

examples/15-TLS.cpp

@@ -1,4 +1,5 @@
 #include <nodepp/nodepp.h>
+#include <nodepp/worker.h>
 #include <nodepp/tls.h>
 #include <nodepp/fs.h>
 
@@ -76,9 +77,12 @@ void client(){
 
 void onMain() {
 
-    if( process::env::get("mode")=="client" ) 
-      { client(); } else { server(); }
+    worker::add( coroutine::add( COROUTINE(){
+    coBegin /*--*/ ; server();
+    process::wait(); coFinish }));
 
-}
+    worker::add( coroutine::add( COROUTINE(){
+    coBegin /*--*/ ; client();
+    process::wait(); coFinish }));
 
-// g++ -o main main.cpp -I./include ; ./main ?mode=client
+}

examples/15-UDP.cpp

@@ -1,4 +1,5 @@
 #include <nodepp/nodepp.h>
+#include <nodepp/worker.h>
 #include <nodepp/udp.h>
 #include <nodepp/fs.h>
 
@@ -77,9 +78,12 @@ void client(){
 
 void onMain() {
 
-    if( process::env::get("mode")=="client" ) 
-      { client(); } else { server(); }
+    worker::add( coroutine::add( COROUTINE(){
+    coBegin /*--*/ ; server();
+    process::wait(); coFinish }));
 
-}
+    worker::add( coroutine::add( COROUTINE(){
+    coBegin /*--*/ ; client();
+    process::wait(); coFinish }));
 
-// g++ -o main main.cpp -I./include ; ./main ?mode=client
+}