代码之家 › 专栏 › 技术社区 › aleixsuau

RxJS:Share()可观察并向每个新订阅者发出最后一个值

angular2-services observable rxjs angular

aleixsuau · 技术社区 · 7 年前

我使用.share()在服务的所有订阅者之间共享一个可观察的:

@Injectable()
export class ChannelsService {
    private store: IChannel[] = [];
    private _own: BehaviorSubject<IChannel[]> = new BehaviorSubject([]);
    readonly own: Observable<IChannel[]> = this._own.asObservable().share();
    ...(the rest of the service basically makes CRUD http request and then calls this._own.next(result) to emit the result to all subscribers)
}

问题:

谢谢

3 回复 | 直到 7 年前

Graham francescalus 7 年前

你可能想要 shareReplay() (自RxJS 5.4.0起)或 publishReplay().refCount()

例如:

this._own.asObservable()
  .publishReplay(1)
  .refCount()
  .take(1);

Jota.Toledo 7 年前

一些小的改进:

@Injectable()
export class ChannelsService {
    private store: IChannel[] = [];
    private _own: BehaviorSubject<IChannel[]> = new BehaviorSubject([]);
    get own(){
      this._own.asObservable();
    }
}

现在,您可以在组件中执行以下操作:

channels$: Observable<IChannel[]> = this.service.own;

别忘了

Jorge Rodríguez Galán 7 年前

您的结果是使用不带初始化值的共享时的预期结果。 Explanation

const subject = new Rx.Subject();

const behaviorWithoutShortcut = subject
  .multicast(new Rx.BehaviorSubject(null))
  .refCount()
  .filter(function (x) { return x !== null; });

const behaviorWithShortcut = subject
  .publishBehavior(null)
  .refCount()
  .filter(function (x) { return x !== null; });

jsbin example

推荐文章

Fahad Subzwari · 我不能用rxjs过滤器过滤记录?

2 年前

Fazla Elahi Md Jubayer · 在rxjs中使用管道内的两个concatmap时,如何提取订阅块内的结果

2 年前

Irakli · 我想以角度显示id相似的数据

2 年前

Akash · 当BehaviorSubject发出两次真值时,使ngOnChange被激发

6 年前

Shamshiel · 将rxjs升级到6后,类型“Observable”上不存在属性“map”

6 年前

Corey Cole Roberto Tyley · 使用RxJS 6。x WebSocketSubject客户端

6 年前

gog · 如何观察rxjs中的属性更改?

6 年前

jesdynf · 在继续之前,如何使角度拦截器延迟?

6 年前

Sean Ivins · 角度2+HttpIntercept:在返回intercept函数之前,等待来自服务器的令牌

6 年前

Kevin Kalitowski · RxJs 6:从Observable获取ConnectableObservable

6 年前