使用可观察对象时，变量返回时未定义

Question

有人能告诉我为什么未定义this.userDataObserver的变量会导致.next（）函数失败吗？在这里撞我的头。

我需要将一些数据推送到可以从其他组件访问的服务变量中（尽量避免使用本地存储）。

有人能帮我理解为什么这个变量在类中被明确设置时是未定义的吗？

import { Injectable } from '@angular/core';
import { Http, Response } from '@angular/http';
import { Observable } from 'rxjs/Observable';
import { Observer } from 'rxjs/Observer';
import 'rxjs/add/operator/map';


@Injectable()
export class globalService {
//Sets logon token
userData:any;
userDataRetrieval: Observable<any>;
userDataObserver: any;
//Sets + updates user info
userInfo: any;
userInfoRetrieval: Observable<any>;
userInfoObserver: any;

constructor() {
    this.userDataRetrieval = new Observable(observer => {
        this.userDataObserver = observer;
    })
    this.userInfoRetrieval = new Observable(observer => {
        this.userInfoObserver = observer;
    })

}
setUser(userData: any) {
    this.userData = userData;
    this.userDataObserver.next(this.userData); this.userDataObserver comes back undefined when calling this function from my component.
}

saveUserInfo(userInfo: any) {
    this.userInfo = userInfo;
    this.userInfoObserver.next(this.userInfo);
}

}

Answer 1

回答您的具体问题：如果您查看可观测数据的来源，您将看到以下内容：

  /**
   * @constructor
   * @param {Function} subscribe the function that is  called when the Observable is
   * initially subscribed to. This function is given a Subscriber, to which new values
   * can be `next`ed, or an `error` method can be called to raise an error, or
   * `complete` can be called to notify of a successful completion.
   */
  constructor(subscribe?: (this: Observable<T>, subscriber: Subscriber<T>) => TeardownLogic) {
    if (subscribe) {
      this._subscribe = subscribe;
    }
  }

这段代码显示了可观察构造函数的参数是一个回调，在订阅可观察构造函数时调用。由于您从未在代码中调用订阅，因此您传递的用于创建可观察性的回调从未被调用。

现在，从你给出的代码示例中，很难理解你想要实现什么。也许你可以提供一些额外的背景/解释，以便获得实现最终目标的指导，不管是什么。

Answer 2

相反，直接调用this.userDataObserver.next（this.userData），您应该使用以下方法，并尝试是否适用于您：

setUser(userData: any) {
    this.userData = userData;
    this.userDataObserver = new Observable(observable => {
        observable.next()
    });
}

让我知道如果这对你不起作用。。。