add send method to Stream

Author: jcouyang

benchmark/react-most-pref.js

@@ -7,7 +7,6 @@ var todolist;
 var context = Most.prototype.getChildContext()
 var most = require('most');
 var log = _=>console.log(_)
-var addToIntentStream = context["__reactive.react.addToIntentStream__"]
 var intentStream = context["__reactive.react.intentStream__"]
 function genActions(intent$){
   var add$ = intent$.filter(x=>x.type=='add')
@@ -24,9 +23,6 @@ function genActions(intent$){
 }
 
 var actions = genActions(intentStream);
-for(var i=0;i<CYCLE;i++){
-  addToIntentStream(actions.add(i))
-}
 var state={value:0}
 actions.addState$.observe(mapper=>{
   state=mapper(state);
@@ -40,6 +36,10 @@ actions.addState$.observe(mapper=>{
   }
 })
 
+for(var i=0;i<CYCLE;i++){
+  intentStream.send(actions.add(i))
+}
+
 /**
 Memory Usage Before: { rss: 32501760, heapTotal: 16486912, heapUsed: 11307128 }
 Memory Usage After: { rss: 34418688, heapTotal: 18550784, heapUsed: 11932336 }

lib/engine/most.es6

@@ -6,26 +6,27 @@ export default function mostEngine() {
   let intentStream = most.create(add => {
     addToIntentStream = add;
     return function dispose(e){
-      addToIntentStream = id;
+      addToIntentStream = null;
       console.log('action stream disposed');
     }
   });
   intentStream.drain();
+  intentStream.send = addToIntentStream;
   let addToHistoryStream = function(){
     console.error('history stream not binded');
   };
   let historyStream = most.create(add => {
     addToHistoryStream = add;
     return function dispose(e){
-      addToHistoryStream = id;
+      addToHistoryStream = null;
       console.log('history stream disposed');
     }
   });
   historyStream.drain();
-
+  historyStream.send = addToHistoryStream;
   function flatObserve(actionsSinks, f){
     return most.from(actionsSinks).join().observe(f);
   }
 
-  return {intentStream, addToIntentStream, flatObserve, historyStream, addToHistoryStream}
+  return {intentStream, flatObserve, historyStream}
 }

lib/react-most.es6

@@ -2,16 +2,12 @@ import React from 'react'
 import mostEngine from './engine/most'
 // unfortunately React doesn't support symbol as context key yet, so let me just preteding using Symbol until react implement the Symbol version of Object.assign
 const intentStream = "__reactive.react.intentStream__";
-const addToIntentStream = "__reactive.react.addToIntentStream__";
 const historyStream = "__reactive.react.historyStream__";
-const addToHistoryStream = "__reactive.react.addToHistoryStream__";
 const flatObserve = "__reactive.react.flatObserve__";
 
 const CONTEXT_TYPE = {
   [intentStream]: React.PropTypes.object,
-  [addToIntentStream]: React.PropTypes.func,
   [historyStream]: React.PropTypes.object,
-  [addToHistoryStream]: React.PropTypes.func,
   [flatObserve]: React.PropTypes.func,
 }
 
@@ -43,14 +39,15 @@ export function connect(main, initprops={}) {
           if(observable(sinks[name]))
             actionsSinks.push(sinks[name]);
           else if(sinks[name] instanceof Function){
-            this.actions[name] = (...args)=>this.context[addToIntentStream](sinks[name].apply(null, args));
+            this.actions[name] = (...args)=>this.context[intentStream].send(sinks[name].apply(null, args));
           }
         }
         this.context[flatObserve](actionsSinks, (action)=>{
           if(action instanceof Function)
             this.setState((prevState, props)=>{
               let newState = action.call(this, prevState,props);
-              this.context[addToHistoryStream](prevState);
+              if(initprops.history)
+                this.context[historyStream].send(prevState);
               return newState;
             });
           else
@@ -78,10 +75,8 @@ let Most = React.createClass({
 
     return {
       [intentStream]: engine.intentStream,
-      [addToIntentStream]: engine.addToIntentStream,
       [flatObserve]: engine.flatObserve,
       [historyStream]: engine.historyStream,
-      [addToHistoryStream]: engine.addToHistoryStream,
     }
   },
   render(){