在rxjs中 一个观察者 有两个订阅者 能否得到 被另一个观察者修改的数据

Question

在rxjs中 一个观察者 有两个订阅者，发送数据后两个订阅者获取的数据是一致的，现在有这样的需求，当其中一个订阅者，得到数据后，将数据进行修改后，能否同步到另外一个观察者，例如：

Subject<MessageData>.next(item new {Tag = 1});
Observable<MessageData>.subscribe((item: MessageData) => {
    console.log(item ) //这里期望输出 Tag=1
    item.Tag = 2
    console.log(item ) //这里期望输出 Tag=2
}
Observable<MessageData>.subscribe((item: MessageData) => {   
    console.log(item ) //这里期望输出 Tag=2
}

Answer 1

没有办法，但可以在你的基础上做一点改进，比如这样：

Subject<MessageData>.next(item new {Tag = 1});
Observable<MessageData>.subscribe((item: MessageData) => {
    console.log(item ) //这里期望输出 Tag=1
    Subject<MessageData>.next(item new {Tag = 2});
    console.log(item ) //这里期望输出 Tag=2
}
Observable<MessageData>.subscribe((item: MessageData) => {   
    console.log(item ) //这里期望输出 Tag=2
}

没错，好傻。

所以这个时候你可以选择 @ngrx/store。