干货-vue 中使用 rxjs 进行非父子组件中传值

npm install rxjs 

import Vue from ‘vue‘
import {subjectServer} from ‘@/utils/subject.server‘;
Vue.use(subjectServer);

import { Observable, BehaviorSubject } from ‘rxjs‘;

class AjaxNoticeOneService {
  subject = new BehaviorSubject(0);
  pushParams(params) {
    this.subject.next(params);
  }
  clearParams() {
    this.subject.next(0);
  }
  getParams() {
    return this.subject.asObservable();
  }
}

export const subjectServer = {
    install(Vue, options) {
        Vue.prototype.$NotificationOneSub = new 
}

this.$NotificationOneSub.pushParams({ key: "moduleActive",value: index})

<script>
import { filter } from "rxjs/operators";
export default { 
 data(){
    return {
       choosePage: -1,
       subscribeSub:null
    }
 },
 mounted(){
    this.subWatch()
  },
  //销毁
  destroyed() {
    if (this.subscribeSub != undefined) {
      this.subscribeSub.unsubscribe();
      this.$NotificationOneSub.clearParams();
    }
  },
  methods: {
    //监听动态表单 接受从home 传来的数据(平行组件中使用甚佳)
    subWatch() {
      const self = this;
      //本地接收提交
      this.subscribeSub = this.$NotificationOneSub
        .getParams()
        .pipe(filter(res => res !== 0))
        .subscribe(item => {
          if (item.key === "moduleActive") {
            this.choosePage = item.value;
            // console.log(item.value);
          }
        });
    },
   }      
};
</script>