如何在Angular 2中创建RxJS主题？

Question

我能够以下面提到的方式在我的角度组件中创建一个Observable

...
...
import { Observable } from 'rxjs/Observable';
..
...
let observable = new Observable( function subscribe(observer) {
        observer.next(1);
        observer.next(2);
        observer.next(3);
        observer.next(4);
        setTimeout(() => {observer.next(5); },9000);
    });

但是我不知道如何创建一个主题，有人可以提供相同的例子吗？

Answer 1

使用带有Angular的Rx.Subject与没有Angular使用它没有什么不同，主要原理是相同的，请看下面的例子

const subject = new Rx.Subject();
const subscription = subject.subscribe(
  (data) => console.log(data),
  (err) => console.log(err),
  () => console.log('Completed')
);

subject.next(1);
subject.next(2);
subject.next(3);
subject.complete();

<script src="https://unpkg.com/@reactivex/[email protected]/dist/global/Rx.umd.js"></script>

您需要创建新的实例Rx.Subject，然后在您需要的地方订阅它，并触发事件。

Answer 2

这是一个吸烟者：http://plnkr.co/edit/jLtFLjWrvHGI0ZPHl10B?p=preview

import {Subject} from 'rxjs/Subject';

@Injectable()
export class MyService {

    public invokeEvent:Subject<any> = new Subject();

    constructor() {}
}

订阅它就像一个可观察的：

  constructor(private _myService: MyService) {
         this._myService.invokeEvent.subscribe((value) => {
           console.log(value); 
         });
       }

并将值推送到它，就像下一个再次观察一样

  ngAfterViewInit(){
      this._myService.invokeEvent.next(1);
  }