Angular2 观察者不见了

Question

我很难坚持观察者。我有一个创建 observable 的组件，在回调中，我捕获了观察者。但后来，我无法得到那个观察者 - 好像我有另一个组件实例。

例子：

import {Component} from 'angular2/core';
import {Observable} from 'rxjs/Observable';

@Component({
  selector: 'users-table',
  templateUrl: './components/users/users-table.html',
  // template: '<button (click)="popup({value: 2})">Clickme</button>'
})
export class UsersTableComponent {

  public userClicked$: Observable<any>;
  public observer: any;
  public thing: number;
  constructor() {

    console.log('Starting UsersTable component');
    this.thing = 1;
    this.userClicked$ = new Observable(observer => {

      this.thing = 2;
      console.log('Observer received:', observer);
      this.observer = observer;
      this.observer.next('Val 1'); // I receive this in an outside component
    }).share(); // This supposedly makes the observable *hot*
  }

  public handle(value) {

    console.log('Value:', value);
    console.log(this.userClicked$);
    console.log('thing:', this.thing); // This is set back to "1
    this.observer.next(user);       // this.observer is undefined
                                    // so it fails here
  }
}

请注意，我是从另一个组件订阅这个的，我确实得到了初始测试值 ('val 1')

另一个组件在监听，在“ngAfterViewInit”中订阅，基本是这样的：

this.usersTableComponent.userClicked$.subscribe(val => { console.log('heard ya:' val); });

我是否遗漏了一些明显的东西？我可以以某种方式直接使用点击处理程序来传递点击用户的东西吗？ （表格中的一行）？

Angular2 Beta 8。

Answer 1

传递给new Observable(observer => { ... }) 的回调仅在调用this.userClicked$.subscribe(...) 时执行，因此，没有订阅者就没有this.observer。

在这种情况下跳过发射：

this.observer && this.observer.next(user);