假设有两个可观察的对象，可观察的A和可观察的B。当A发出一个值时，我想等待1秒，然后发出B的最新值。如果A在等待1秒时发出另一个值，我想让它忘记前一个值，再等待1秒(就像switchMap一样)。我怎么才能做到这样的行为呢？
浏览 11提问于2018-02-02得票数 1
回答已采纳
我正在实现高速缓存HTTP结果的角度应用程序。据我所知，以下两种代码都可以工作，但我需要知道它们是在执行完全相同的，还是遗漏了一些重要的东西？
浏览 0提问于2017-06-07得票数 8
回答已采纳
我有两个观察值A和B，我想创建一个从B发出最新值的观察值，但是如果B还没有发出任何东西，它就会发出来自A的最新值。我是这样想的：但这似乎有点违反直觉，我希望有一种更具可读性的方法。有没有更规范的</
浏览 0提问于2018-03-16得票数 2
我需要按照以下顺序执行以下操作：
使用来自A和B的最新值来作出决定这个动作是这样分派的(假
浏览 3提问于2018-05-30得票数 1
我有一个SignalProducer，ProducerA，它以不同的时间间隔发送值。我正在尝试收集SignalProducer发出的最新N值，并创建一个新的生产者ProducerB，它发出一个包含最新N值的数组。ProducerB应该在ProducerA发出前N个值时开始发出值</em
浏览 2提问于2016-01-08得票数 2
我有两个可以观察到的，我想和combineLatest结合起来const o2 = of('content from o2'); .subscribe(result => console.log(result));
正如我所理解的，当任何可观测到的combineLatest发出时，它将合并所有可观测<em
浏览 0提问于2018-08-03得票数 8
回答已采纳
我会给出充分的解释，但基本上我需要确保
我有两个可观测值，每个值发出0或1个值，然后完成：
//1. lazy observable that emit 0 or two value created at time of subscription首先发出缓存值(如果
浏览 0提问于2019-06-07得票数 2
我正在读一本关于角的书，但是我找不到关于lambda表达式[hours, rate]) => this.total = hours * rate这个括号用法的任何文档。虽然我知道我可以从lambda表达式的内部使用这些参数(小时和速率)。我可以在哪里找到关于这个用法的文档。
注意:我知道combineLatest所做的事情，我不明白的是带有这些括号的lambda表达式的用法。
浏览 2提问于2019-01-22得票数 1
回答已采纳
1回答
我有一个简单的用法，我似乎搞不懂。A在B发出它的第一项后开始发射项目，B可以继续发出项，这将不再影响A。
我需要这个，因为A需要B发出的第一个值才能开始发射。
浏览 5提问于2017-12-12得票数 1
回答已采纳
我有两个来源的溪流，我想听他们。所需经费如下：
...storeTwo.getValue(), 1: {id: 1} ids: [1]上面的代码在一个接一个地发射时运行
浏览 0提问于2018-02-01得票数 2
回答已采纳
如果我从第一个可观察到的地方删除delay，一切都会正常工作。如果我改为combineLatest([obs1, obs2])，一切都很好。如果combineLatest修复了我的bug，我可以接受--但我想了解其中<em
浏览 0提问于2019-09-09得票数 2
回答已采纳
我在组件中定义了一个可观察的(结果$)，并通过异步管道在其模板上显示它。可观测性是通过combineLatest进行的其他两个可观测数据的组合(第一个$，第二个$)。如果其中一个可观测到的，或者两者都发布得太早(在我发现ngAfterContentInit之前)，那么可观察到的结果就不会发出一个值。因为可观测值在此之前发出<em
浏览 0提问于2019-02-07得票数 7
回答已采纳
我想用这样的方式加入： this.service1.dataSourceIsAReplaySubject, console.log('inside subscribe values is', values);我能做些什么来等待两个ReplaySubjects或者一
浏览 3提问于2016-11-15得票数 5
回答已采纳
(使用角2& NgRedux 2和ngrx 5.0.3)很想帮忙，我很困惑。(使用debounceTime(1)而不是节流阀，我们在最后只得到了1条退出日志，似乎不可能每样东西都少于1ms！)在中间有一个
浏览 2提问于2017-01-24得票数 0
我有一个可观察的对象，我希望在经过一段时间(超时)后发出一个默认元素，同时保持流仍然打开以在将来发出新值。我该怎么做呢？我尝试通过将原始流与另一个去反弹值的流合并来实现这一点，同时将去反弹值映射到我想要的默认值。myDefaultValue})
myStream = rx.merge(originalStream, defaul
浏览 0提问于2017-07-22得票数 1
回答已采纳
例如，我让A，B，C，D可流动对象独立地发射。例如，这映射到Foo的位置： Flowable<Foo> fooStream = Flowable.combineLatest(A,B,C,D -> Foo::new); 每当A、B、C或D发出更新时，它都会发出。一个新的Foo被发射到下游。 我可以使用哪种运算符组合(如果有的话)将(A，B，C，D)的最新结果合并到Foo中，只有一些s
浏览 28提问于2019-02-07得票数 0
我有多个可观察到的值，它们在页面的生存期内发出值。Observable;filterData$: Observable;
在任何时候，用户都可以单击“下载”按钮，并获得JSON，并组合上一次从这些可观察到的值中发出的值).subscribe(([chart, table, filter]) => downloadJson(chart, table, filter
浏览 2提问于2020-09-08得票数 2
回答已采纳
1回答
在我的应用程序中，我有两个数据流，我希望将它们组合成一个包含一对值的数据流。但是，当Flow A发出一个新值时，组合的Flow应该发出一对空值，直到Flow B发出一个新值。可以这样想： Flow A A --------------------------> B -----------------
浏览 29提问于2021-05-10得票数 2
pipe(take(6));merged.subscribe(x => console.log(x));我尝试使用zip，但它不会使用最新版本。检查下面的屏幕截图，查找我想要的缺失值。我
浏览 4提问于2021-02-27得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
