Angular2 可观察到的不工作

Question

我正在使用 peerjs 库来建立聊天。每次收到新消息时，我都在尝试做一个可观察的事件来触发一个事件。

this.data = new Observable(observer => {
                   this.peer.on('connection', (data) => {
                    alert("TRIGGER");
                    observer.next(data);   
                });
             })


             this.peerMessages = this.data.subscribe(message => {
                alert(message);
            });

我可以看到第一个警报，但第二个警报从未触发。我没有从浏览器控制台收到任何错误。我做错了什么？

我正在尝试使用观察者，因为我想更改 angular 组件中的变量而不是 alert(message)。

Answer 1

代码看起来不错，但请确保导入所需的一切。例如，如果使用 rxjs:

import { Observable, ... } from 'rxjs/Observable';

Angular2 可观察到的不工作

Angular2 observable not working

javascript

peerjs

angular