indent

Author: wx-ps

src/methods/createObservableFunction.js

@@ -1,7 +1,7 @@
 import { Rx, hasRx, warn } from '../util'
 
 /**
- * @name vue.prototype.$createObservableFunction
+ * @name Vue.prototype.$createObservableFunction
  * @description Creates an observable from a given function name.
  * @param {String} functionName Function name
  * @param {Boolean} [passContext] Append the call context at the end of emit data?
@@ -23,7 +23,7 @@ export default function createObservableFunction (functionName, passContext) {
     return
   }
 
-  if(vm[functionName] !== undefined){
+  if (vm[functionName] !== undefined) {
     warn(
       'Potential bug: ' +
       `Method ${functionName} already defined on vm and has been overwritten by $createObservableFunction.` +
@@ -32,26 +32,25 @@ export default function createObservableFunction (functionName, passContext) {
     )
   }
 
-  let creator = function (observer) {
-
+  const creator = function (observer) {
     vm[functionName] = function () {
-      let args = Array.from(arguments);
-      if(passContext){
-        args.push(this);
-        observer.next(args);
-      }else{
+      const args = Array.from(arguments)
+      if (passContext) {
+        args.push(this)
+        observer.next(args)
+      } else {
         if (args.length <= 1) {
-          observer.next(args[0]);
+          observer.next(args[0])
         } else {
-          observer.next(args);
+          observer.next(args)
         }
       }
-    };
-    return function() {
-      delete vm[functionName];
-    };
-  };
+    }
+    return function () {
+      delete vm[functionName]
+    }
+  }
 
-  //Must be a hot stream otherwise function context may overwrite over and over again
-  return Rx.Observable.create(creator).share();
+  // Must be a hot stream otherwise function context may overwrite over and over again
+  return Rx.Observable.create(creator).share()
 }

test/test.js

@@ -318,7 +318,6 @@ test('$eventToObservable() with lifecycle hooks', done => {
   })
 })
 
-
 test('$createObservableFunction() with no context', done => {
   const vm = new Vue({
     created () {
@@ -337,7 +336,7 @@ test('$createObservableFunction() with no context', done => {
 test('$createObservableFunction() with muli params & context', done => {
   const vm = new Vue({
     created () {
-      this.$createObservableFunction('add',true)
+      this.$createObservableFunction('add', true)
         .subscribe(function (param) {
           expect(param[0]).toEqual('hola')
           expect(param[1]).toEqual('mundo')
@@ -347,6 +346,6 @@ test('$createObservableFunction() with muli params & context', done => {
     }
   })
   nextTick(() => {
-    vm.add('hola','mundo')
+    vm.add('hola', 'mundo')
   })
 })