cover fromEvent and fromPromise

Author: jcouyang

lib/__tests__/react-most-test.jsx

@@ -3,7 +3,7 @@ import ReactDOM from 'react-dom';
 import TestUtils from 'react-addons-test-utils';
 import * as most from 'most';
 import {compose} from 'ramda';
-import Most, {connect} from 'react-most';
+import Most, {connect} from '../react-most';
 import {stateStreamOf, stateHistoryOf,
         intentStreamOf, intentHistoryOf,
         run, dispatch,
@@ -65,6 +65,22 @@ describe('react-most', () => {
       expect(stateHistoryOf(counter)[2].count).toBe(3)
     })
 
+    it('async action', ()=> {
+      let counterWrapper = TestUtils.renderIntoDocument(
+        <Most engine={Engine}>
+          <Counter history={true} />
+        </Most>
+      )
+      let counter = TestUtils.findRenderedComponentWithType(counterWrapper, Counter)
+      counter.actions.inc();
+      counter.actions.fromEvent({type:'inc'});
+      return counter.actions.fromPromise(Promise.resolve({type:'inc'}))
+                    .then(()=>{
+                      expect(stateHistoryOf(counter)[2].count).toBe(3)
+                    })
+
+    })
+
     it('sink can also generate intent', ()=> {
       let counterWrapper = TestUtils.renderIntoDocument(
         <Most engine={Engine}>

lib/react-most.js

@@ -123,10 +123,10 @@ function actionsAndSinks(sinks, self){
   let _sinks = [];
   let _actions = {
     fromEvent(e, f=x=>x){
-      self.context[INTENT_STREAM].send(f(e));
+      return self.context[INTENT_STREAM].send(f(e));
     },
     fromPromise(p){
-      p.then(x=>self.context[INTENT_STREAM].send(x));
+      return p.then(x=>self.context[INTENT_STREAM].send(x));
     }
   };
   for(let name in sinks){

package.json

@@ -21,7 +21,7 @@
     "build": "babel lib -d ./ --ignore '__tests__' && npm run license",
     "prebrowser": "npm run build",
     "browser": "browserify -r react -r most -r most-subject -o dist/vendor.js && browserify -s Most -x react -x most -x most-subject react-most.js  -o dist/react-most.js",
-    "test": "jest",
+    "test": "jest --coverage",
     "prepublish": "npm run build",
     "testWDebugger": "node --harmony $(which bugger) ./node_modules/jest-cli/bin/jest.js --runInBand"
   },