我可以用下面提到的方式在我的角度组件中创建一个观察值
...
...
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);
});但是我不知道如何创建一个主题,有人可以提供一个相同的例子吗?
发布于 2016-11-05 22:36:54
这里有一个插入器: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);
});
}并使用next将值像可观察对象一样再次推送到它。
ngAfterViewInit(){
this._myService.invokeEvent.next(1);
}https://stackoverflow.com/questions/40439327
复制相似问题