commit

Author: kenokabe-hue

package.json

@@ -1,6 +1,6 @@
 {
   "name": "timeengine",
-  "version": "5.0.3",
+  "version": "5.1.0",
   "description": "TimeEngine is a tiny, simple yet versatile JavaScript library of event system. Built for Declarative and Functional Reactive Programming.",
   "main": "timeengine.js",
   "scripts": {

react-test/index.jsx

@@ -40,25 +40,23 @@
     const THETA = DEG / 180 * Math.PI; //radian
     const G = 9.8; //gravity const
 
-    //10msec time resolution
-    //t seconds elapsed
+    //t seconds elapsed 10msec time resolution
     const t = __
       .intervalSeq(Immutable.Range(), 10)
       .__((count) => (count * 10 / 1000));
     const x = t.__((t) => V0 * Math.cos(THETA) * t);
     const y = t.__((t) => V0 * Math.sin(THETA) * t - 1 / 2 * G * Math.pow(t, 2));
-    //==============================================================
+    //===================================================
     const Drawscale = 1; //1 dot = 1 meter
     const __seqEl = __([x, y]) //atomic update
-      .__(([x, y]) => (
+      .__(([x, y]) => (<circle r="3" fill="red"
+        cx = {50 + x * Drawscale} cy = {250 - y * Drawscale}/>));
+    return (
       <div>
         <svg height = "250"  width = "100%">
-            <circle r="3" fill="red"
-        cx = {50 + x * Drawscale} cy = {250 - y * Drawscale}/>
+          {__Component(__seqEl)}
         </svg>
-      </div>));
-
-    return __Component(__seqEl);
+      </div>);
   };
 
   const ButtonComponent = () => {
@@ -67,11 +65,12 @@
       __clicked.t = true;
     };
 
+
     const __seqEl = __([__clicked])
       .__(() => (<div>{PhysicsComponent()}</div>));
 
     return (<div>
-      <div><button onClick={onClick}>Physics Start</button></div>
+      <div><button onClick={onClick()}>Physics Start</button></div>
       {__Component(__seqEl)}
       </div>
       );

test.js

@@ -8,12 +8,13 @@
     .log('timeengine test started...');
 
   const a = __();
-  const b = __();
-  const c = __([a, b]).__(([a, b]) => (a + b));
+  const b = __([a]);
+  //  const c = __([a, b]).__(([a, b]) => (a + b));
 
+  //var c = a.__([b]);
   const timeseq1 = a.log('a');
   const timeseq2 = b.log('b');
-  const timeseq3 = c.log('c');
+  //  const timeseq3 = c.log('c');
 
   const timeseq4 = __.intervalSeq(Immutable.Range(0, 1), 1000)
     .__(() => {

timeengine.es

@@ -20,6 +20,7 @@
     });
     seq.IndexOnTimestamp = {};
     seq.TimestampOnIndex = {};
+    seq.done = 0;
     //-----------------
     Object.keys(__.api).map((api) => {
       seq[api] = __.api[api](__, seq, store);
@@ -41,22 +42,24 @@
               seq[seq.length] = seq.valOnT;
             }
             //----------------------
-            Object.keys(seq.updatedFor).map((key) => {
-              seq.updatedFor[key] = 1;
-            });
-            seq.us.map((u) => {
-              //-------------------
-              const dsAllUpdated = u.ds
-                .map((d) => (d.updatedFor[u.id]))
-                .reduce((a, b) => (a * b));
-              if (dsAllUpdated === 1) {
-                u.t = u.eq(tval); //propagate
-                //--clear updated ds in non-interference way--
-                u.ds.map((d) => {
-                  d.updatedFor[u.id] = 0;
-                });
-              }
-            });
+            if (seq.done === 0) {
+              Object.keys(seq.updatedFor).map((key) => {
+                seq.updatedFor[key] = 1;
+              });
+              seq.us.map((u) => {
+                //-------------------
+                const dsAllUpdated = u.ds
+                  .map((d) => (d.updatedFor[u.id]))
+                  .reduce((a, b) => (a * b));
+                if (dsAllUpdated === 1) {
+                  u.t = u.eq(tval); //propagate
+                  //--clear updated ds in non-interference way--
+                  u.ds.map((d) => {
+                    d.updatedFor[u.id] = 0;
+                  });
+                }
+              });
+            }
           }
         }
       });

timeengine.js

@@ -33,6 +33,7 @@
     });
     seq.IndexOnTimestamp = {};
     seq.TimestampOnIndex = {};
+    seq.done = 0;
     //-----------------
     Object.keys(__.api).map(function (api) {
       seq[api] = __.api[api](__, seq, store);
@@ -55,24 +56,26 @@
             seq[seq.length] = seq.valOnT;
           }
           //----------------------
-          Object.keys(seq.updatedFor).map(function (key) {
-            seq.updatedFor[key] = 1;
-          });
-          seq.us.map(function (u) {
-            //-------------------
-            var dsAllUpdated = u.ds.map(function (d) {
-              return d.updatedFor[u.id];
-            }).reduce(function (a, b) {
-              return a * b;
+          if (seq.done === 0) {
+            Object.keys(seq.updatedFor).map(function (key) {
+              seq.updatedFor[key] = 1;
             });
-            if (dsAllUpdated === 1) {
-              u.t = u.eq(tval); //propagate
-              //--clear updated ds in non-interference way--
-              u.ds.map(function (d) {
-                d.updatedFor[u.id] = 0;
+            seq.us.map(function (u) {
+              //-------------------
+              var dsAllUpdated = u.ds.map(function (d) {
+                return d.updatedFor[u.id];
+              }).reduce(function (a, b) {
+                return a * b;
               });
-            }
-          });
+              if (dsAllUpdated === 1) {
+                u.t = u.eq(tval); //propagate
+                //--clear updated ds in non-interference way--
+                u.ds.map(function (d) {
+                  d.updatedFor[u.id] = 0;
+                });
+              }
+            });
+          }
         }
       }
     });