Rxjs ReplaySubject & pairwise

问题描述

我们可以将 policy=data.loc[data['table_col_name']=='agent',['node_name','src_name']] print(policy) pairwise() 一起使用,而不是将 ReplaySubject 与第一个发出的值一起使用吗?

使用 BehaviorSubject 我可以在构造函数中设置第一个值,这样 BehaviorSubject 将与第一个 pairwise() 一起使用。但在这里我需要重播行为,所以有什么建议吗?

解决方法

使用 startWith 添加初始值。

subject.pipe(
  startWith('first'),pairwise()
)