Began adding an Application module

Author: bryanjos

examples/send_receive.js

@@ -1,30 +1,43 @@
 "use strict";
 
-import { ProcessSystem, GenServer } from "../src/processes";
+import { ProcessSystem, GenServer, Application } from "../src/processes";
 self.system = self.system || new ProcessSystem();
 
+let myApp = {
+  start: function(type, args){
+    let pid = self.system.spawn(function*(){
+      var pid1 = self.system.spawn_link(function*(){
+          while(true){
 
-var pid1 = system.spawn(function*(){
-    while(true){
+            yield self.system.receive(function(value){
+              return console.log(value);
+            });
 
-      yield system.receive(function(value){
-        return console.log(value);
+            self.system.send(pid2, "message from 1");
+          }
       });
 
-      system.send(pid2, "message from 1");
-    }
-});
+      self.system.register("Sally", pid1);
 
-system.register("Sally", pid1);
 
+      var pid2 = self.system.spawn_link(function*(){
+        while(true){
+          
+          self.system.send("Sally", "message from 2");
 
-var pid2 = system.spawn(function*(){
-  while(true){
-    
-    system.send("Sally", "message from 2");
+          yield self.system.receive(function(value){
+            return console.log(value);
+          });
+        }
+      });
 
-    yield system.receive(function(value){
-      return console.log(value);
+      yield self.system.receive(function(value){
+        return Symbol.for("no_match");
+      });      
     });
+
+    return [Symbol.for("ok"), pid];
   }
-});
+};
+
+let pid = Application.start(myApp);

src/processes.js

@@ -1,3 +1,4 @@
 export { default as ProcessSystem } from "./processes/process_system";
 export { default as GenServer } from "./processes/otp/gen_server";
 export { default as GenEvent } from "./processes/otp/gen_event";
+export { default as Application } from "./processes/otp/application";

src/processes/otp/application.js

@@ -0,0 +1,5 @@
+function start(app, type = Symbol.for("temporary")){
+  return app.start(type, []);
+}
+
+export default { start };

src/processes/pid.js

@@ -10,7 +10,7 @@ class PID {
   }
 
   toString(){
-    return "PID#<0." + id + ".0>";
+    return "PID#<0." + this.id + ".0>";
   }
 }
 

src/processes/process.js

@@ -5,8 +5,6 @@ import Mailbox from "./mailbox";
 import ProcessSystem from "./process_system";
 import States from "./states";
 
-const NOMSG = Symbol();
-
 function is_sleep(value){
   return Array.isArray(value) && value[0] === States.SLEEP;
 }
@@ -80,13 +78,16 @@ class Process {
   }
 
   receive(fun){
-    let value = NOMSG;
+    let value = States.NOMATCH;
     let messages = this.mailbox.get();
 
     for(let i = 0; i < messages.length; i++){
       try{
         value = fun(messages[i]);
-        this.mailbox.removeAt(i);
+        if(value !== States.NOMATCH){
+          this.mailbox.removeAt(i);
+          break;
+        }
       }catch(e){
         this.exit(e);
       }
@@ -121,7 +122,7 @@ class Process {
 
         let result = function_scope.receive(value[1]);
 
-        if(result === NOMSG){
+        if(result === States.NOMATCH){
           this.system.suspend(function() { 
             function_scope.system.set_current(function_scope.pid); 
             function_scope.run(machine, step); 

src/processes/process_system.js

@@ -21,11 +21,12 @@ class ProcessSystem {
     this.suspended = new Map();
 
     let process_system_scope = this;
-    this.main_process = this.spawn(function*(){
+    this.main_process_pid = this.spawn(function*(){
         while(true){
           yield process_system_scope.sleep(10000);
         }
     });
+    this.set_current(this.main_process_pid);
   }
 
   static * run(fun, args, context = null){
@@ -65,13 +66,13 @@ class ProcessSystem {
   }
 
   link(pid){
-    this.links.get(this.current_process.pid).add(pid);
-    this.links.get(pid).add(this.current_process.pid);  
+    this.links.get(this.pid()).add(pid);
+    this.links.get(pid).add(this.pid());  
   }
 
   unlink(pid){
-    this.links.get(this.current_process.pid).delete(pid);
-    this.links.get(pid).delete(this.current_process.pid);   
+    this.links.get(this.pid()).delete(pid);
+    this.links.get(pid).delete(this.pid());   
   }
 
   set_current(id){
@@ -104,9 +105,8 @@ class ProcessSystem {
     this.unregister(pid);
     this.scheduler.removePid(pid);
 
-    if(this.links.get(pid)){
-      for (let linkpid in this.links.get(pid).entries()) {
-        linkpid = Number(linkpid);
+    if(this.links.has(pid)){
+      for (let linkpid of this.links.get(pid)) {
         this.exit(linkpid, exitreason);
         this.links.get(linkpid).delete(pid);
       }

src/processes/states.js

@@ -10,5 +10,6 @@ export default {
   SUSPENDED: Symbol.for("suspended"),
   STOPPED: Symbol.for("stopped"),
   SLEEP: Symbol.for("sleep"),
-  EXIT: Symbol.for("exit")
+  EXIT: Symbol.for("exit"),
+  NOMATCH: Symbol.for("no_match")
 }