Làm thế nào để tạo chủ đề RxJS trong Angular 2?

Question

tôi có thể tạo ra một quan sát ở phần góc của tôi ở dưới đây đề cập cách

... 
... 
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); 
    }); 

Nhưng tôi không biết làm thế nào để tạo ra một chủ đề, có thể một số một cung cấp một ví dụ cho giống nhau không?

Answer 1

Sử dụng Rx.Subject với góc nó không khác nhau từ việc sử dụng nó mà không góc, nguyên tắc chính là như nhau, nhìn vào ví dụ dưới đây

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/rxjs@5.0.0-beta.7/dist/global/Rx.umd.js"></script> 

Bạn cần phải thực hiện ví dụ mới Rx.Subject, sau đó đăng ký với nơi bạn cần và kích hoạt sự kiện.

Answer 2

Dưới đây là một plunker: http://plnkr.co/edit/jLtFLjWrvHGI0ZPHl10B?p=preview

import {Subject} from 'rxjs/Subject'; 

@Injectable() 
export class MyService { 

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

    constructor() {} 
} 

đăng ký với nó như một quan sát được:

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

và đẩy giá trị cho nó giống như một quan sát một lần nữa với tới

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