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

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

angular2-services observable rxjs angular

aleixsuau · 技术社区 · 9 年前

我使用.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 回复 | 直到 9 年前

Graham francescalus 8 年前

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

例如:

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

Jota.Toledo 9 年前

一些小的改进:

@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 9 年前

您的结果是使用不带初始化值的共享时的预期结果。 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

推荐文章

Sudharsan Venkatraj · 如何在Angular2中发布图像?

8 年前

Antony Sampath Kumar Reddy · 在angular 2及以上版本中发出“ng build--prod”命令时,为什么生成块文件

8 年前

Nasrul Bharathi · 如何在没有@Output decorator的情况下使用EventEmitter?

8 年前

Jayesh Ambali · TypeError:对象不支持属性或方法“map”-AngularJS2

8 年前

Prateek Ratnaker · 更新服务中声明的变量时更新组件变量

8 年前

Sakkeer A · 如何在单击Angular 2中的按钮时实现全屏窗口功能?

8 年前

Brijesh Mavani · 如何将angular 2服务中的数组传递给asp。net web API?

8 年前

Amit Sawant · 无法访问Angular 2组件中addEventListener()中的“this”上下文

8 年前

Miguel Teixeira · Angular2:Http。获取未定义的映射

8 年前

Muskett · Angular2向单页应用程序添加JSON数据

8 年前