行为主体初值null？

Question

private customer: Subject<Object> = new BehaviorSubject<Object>(null);

setCustomer(id, accountClassCode) {
    this.customer.next({'id': id, 'accountClassCode': accountClassCode});
}

getCustomer() {
    return this.customer.asObservable();
}

我正在使用这部分代码，但我收到一个错误，找不到空的 id。有没有办法获取不为空的初始值？

Answer 1

另一种方法是使用管道进行过滤，直到收到非空值。也可以使用 takeWhile 来完成。

.pipe(filter(val => !!val)).subscribe(x => {});

Answer 2

由于对象可以为空，更好的选择是像这样推断类型

 private customer = new BehaviorSubject<Customer|null>(null);

Answer 3

我发现在很多情况下，我想要 ReplaySubject(1) 的简单性，但也想要 BehaviorSubject 的 value 属性，即它存储您最近的检索值而无需订阅。考虑到需要广播的初始值，使用BehaviorSubject 总是很烦人，这是我很少想要的条件。为此，我创建了自己的CurrentSubject。

import { ReplaySubject } from "rxjs";

export class CurrentSubject<T> extends ReplaySubject<T> {
    value: T;

    set(value?: T) {
        this.value = value;
        this.next(value);
    }
}

我想覆盖next 方法，但由于某种原因我无法让它工作，所以我选择了一个名为set 的方法。我的覆盖尝试看起来像这样......

export class CurrentSubject<T> extends ReplaySubject<T> {
    value: T;

    next(value?: T) {
        this.value = value;
        super.next(value);
    }
}

我不知道为什么覆盖不起作用。

Answer 4

尝试以这种方式构建您的服务：

服务：

@Injectable()
export class MyService {
    customerUpdate$: Observable<any>;

    private customerUpdateSubject = new Subject<any>();

    constructor() {
        this.customerUpdate$ = this.customerUpdateSubject.asObservable();
    }

    updatedCustomer(dataAsParams) {
        this.customerUpdateSubject.next(dataAsParams);
    }
}

记得将MyService添加到提供者。

你更新你的客户端（如果是这种情况），你做这样的事情：

组件（触发的那个）：

constructor(private myService: MyService) {
        // I'll put this here, it could go anywhere in the component actually
        // We make things happen, Client has been updated
        // We store client's data in an object
        this.updatedClient = this.myObjectWithUpdatedClientData;  // Obj or whatever you want to pass as a parameter
        this.myService.updatedCustomer(this.updatedClient);
    }

组件（订阅的那个）：

this.myService.customerUpdate$.subscribe((updatedClientData) => {
            // Wow! I received the updated client's data
            // Do stuff with this data!
        }
    );

据我了解，您正试图将数据从一个组件传递到另一个组件。您获取客户的数据并通过您的应用程序将其发送到另一个组件，对吗？这就是我发布此解决方案的原因。

如果您对其他类型的订阅感兴趣，请阅读以下内容：

Angular 2 special Observables (Subject / Behaviour subject / ReplaySubject)

Answer 5

BehaviorSubject 的目的是提供初始值。它可以是null 或其他任何东西。如果无法提供有效的初始值（当用户 ID 未知时），则不应使用它。

ReplaySubject(1) 提供类似的行为（在订阅时发出最后一个值），但在使用 next 设置之前没有初始值。

应该是这样的

private customer: Subject<Object> = new ReplaySubject<Object>(1);