fix warning (#39)

Author: regou

src/directives/stream.js

@@ -11,6 +11,15 @@ export default {
     const event = binding.arg
     const streamName = binding.expression
 
+    if (!Rx.Observable.fromEvent) {
+      warn(
+        `No 'fromEvent' method on Observable class. ` +
+        `v-stream directive requires Rx.Observable.fromEvent method. ` +
+        `Try import 'rxjs/add/observable/fromEvent' for ${streamName}`,
+        vnode.context
+      )
+      return
+    }
     if (isSubject(handle)) {
       handle = { subject: handle }
     } else if (!handle || !isSubject(handle.subject)) {
@@ -21,14 +30,6 @@ export default {
         vnode.context
       )
       return
-    } else if (!Rx.Observable.fromEvent) {
-      warn(
-        `No 'fromEvent' method on Observable class. ` +
-        `v-stream directive requires Rx.Observable.fromEvent method. ` +
-        `Try import 'rxjs/add/observable/fromEvent' for ${streamName}`,
-        vnode.context
-      )
-      return
     }
 
     const subject = handle.subject

test/test.js

@@ -1,11 +1,24 @@
+'use strict'
 const Vue = require('vue/dist/vue.js')
 const VueRx = require('../dist/vue-rx.js')
-const Rx = require('rxjs')
+
+//library
+const Observable = require('rxjs/Observable').Observable;
+const Subject = require('rxjs/Subject').Subject;
+const Subscription = require('rxjs/Subscription').Subscription;
+require('rxjs/add/observable/fromEvent');
+
+//user
+require('rxjs/add/operator/map');
+require('rxjs/add/operator/startWith');
+require('rxjs/add/operator/scan');
+require('rxjs/add/operator/pluck');
+
 
 const miniRx = {
-  Observable: Rx.Observable,
-  Subscription: Rx.Subscription,
-  Subject: Rx.Subject
+  Observable,
+  Subscription,
+  Subject
 }
 
 Vue.config.productionTip = false
@@ -15,7 +28,7 @@ const nextTick = Vue.nextTick
 
 function mock () {
   let observer
-  const observable = Rx.Observable.create(_observer => {
+  const observable = Observable.create(_observer => {
     observer = _observer
   })
   return {