Subscribe with each stream without enclosing with Observable.race

nju33 · Oct 15, 2017 · 230e451 · 230e451
1 parent ef22faf
commit 230e451
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/src/renderer/components/street.vue b/src/renderer/components/street.vue
@@ -291,7 +291,7 @@ export default {
          */
         const reserveLoad = () => {
           return setTimeout(() => {
-            // console.log('Try LOAD');
+            console.log('Try LOAD');
             this.getItems$.next({
               type: 'LOAD',
               ctx: {resolve() {}},
@@ -346,11 +346,13 @@ export default {
           return Rx.Observable.never();
         })
 
-      const subscription = Rx.Observable.race(
-        interval$,
-        scroll$,
-      ).subscribe();
-      this.subscriptions.push(subscription);
+      // const subscription = Rx.Observable.race(
+      //   interval$,
+      //   scroll$,
+      // ).subscribe();
+      // const
+      this.subscriptions.push(interval$.subscribe());
+      this.subscriptions.push(scroll$.subscribe());
     })();
 
     return {