有没有办法等待subscribe调用返回的第一个值？ 例如，在以下代码中： async getValue(...) { myObs$.subscribe(val => { }我的问题是:有没有可能在不调用第一次()调用的行的情况下返回一个Promise，而只是等待我在subscribe中第一次得到结果？
浏览 43提问于2019-01-26得票数 0
所以，在我过去打电话给myMethod.then()的地方，我转到了myMethod.first().subscribe()。我做到了这一点，而不仅仅是subscribe()，因为我希望能够自动完成和清理可观察的订阅。我对此的理解是否正确，这是否一种合理的方法？
浏览 2提问于2017-09-06得票数 1
回答已采纳
Example1通过Observable.Interval创建可观察对象： var observable1 = Observable.Interval(TimeSpan.FromSeconds(1)).Take(3); observable1.Subscribe(replaySubject1); // subscribe
r
浏览 20提问于2019-10-14得票数 1
回答已采纳
2回答
let observable = new Subject<void>();
observable.subscribe(() => console.log("I want to be first!"));
obser
浏览 5提问于2020-11-01得票数 2
回答已采纳
3回答
我使用的是RxJava，我有一个包含多个项目的Observable。我想做的是在第一项上运行函数A，在所有项上运行函数B，在Observable完成时运行函数C： | | | |我已经有了以下解决方案，但它看起来很难看，我怀疑有更好的方法可以做到这一点： new Action1<Item>() {boolean first = true;
浏览 14提问于2015-09-02得票数 4
回答已采纳
例如，如果我有下面的链： .takeFirst(() => console.log('potato')) return this.innerObservable(('tomato')); .subscribe
浏览 0提问于2017-05-27得票数 4
在Rxjs中，我知道subscribe方法在可观察的执行中有三种类型的值:next、error、complete.It。在subscribe()方法中编写箭头函数很容易，但我在某个地方遇到了subscribe({})方法，我不知道它在means.for示例中是什么：observable.subscribe({
next: x => console.log('
浏览 0提问于2016-11-09得票数 0
但我不能调用Subject.onNext()，因为我从其他Observables获取其他项 subject.subscribe(observer)
// by the firstobservable, that a
浏览 13提问于2018-03-05得票数 1
在角5中，我想使用第一个()方法，如下所示： this.mode = mode;我是这样进口的：import { first } from 'rxjs/operators/first';。但是，它拒绝工作，只提供您在标题：[ts] Property 'first' does not exist on type 'O
浏览 0提问于2018-05-22得票数 11
回答已采纳
我所拥有的非常简单的代码是这样的：observable1 subject.OnNext, {
subject.OnCompleted();
浏览 0提问于2011-11-23得票数 3
回答已采纳
1回答
直觉上，我认为first()和take(1)是相等的，并且做的也是一样的。然而，通过深入挖掘源代码，first()被定义为take(1).single()。
这里的single()有什么用呢？
浏览 55提问于2016-01-27得票数 34
回答已采纳
2回答
= Rx.Observable.timer(0, 1000).map(val => doSomething(val));
const second = observable.subscribe(val => console.log("second:", valRx.
浏览 0提问于2018-05-15得票数 5
回答已采纳
4回答
以以下为例：我在这里试图实现的是在任何给定时间StartWith和Replay位确保始终有一个值，并且在实际代码中需要RefCount位来检测何时可以执行一些处理操作。因此，为了模拟这个“任意给定的时间”部分，让我们尝试在5秒后获得最新的值：
Observable.Timer(TimeSpan.FromSeconds(5)).Subscribe</em
浏览 1提问于2016-10-17得票数 3
回答已采纳
例如，有可观察到的ox和oy。oy中被调用的请求的数据依赖于来自ox的数据yData: string = "";
data => {xData =data;}, () => { data => {yData
浏览 0提问于2016-08-10得票数 10
回答已采纳
2回答
switchMap(d => this.http.get(d)) switchMap(j => this.http.get(j)) )
.subscribe
浏览 11提问于2020-01-03得票数 2
回答已采纳
1回答
我尝试过使用forkJoin和zip，但是最后一行没有记录任何内容。this.db.list<ChatByUser>(`chats_by_user/${this.userService.user.id}`).valueChanges().first().subscribe(chatsByUser => {
chatsByUser.forEach(chatByUser =>(obs
浏览 1提问于2018-06-21得票数 0
回答已采纳
2回答
示例代码：const test2$ = Rx.Observable.interval(1000)
const firstSub = test2$ .subscribe()
// This subscription need
浏览 6提问于2017-03-08得票数 1
回答已采纳
我有一个可观测的，它使用scan运算符进行转换，所以它总是根据当前和以前的值(或初始值)发出一个值。Disposable first = observable.subscribe(System.out::println); // "zero"first.dispose();Disposable secon
浏览 5提问于2017-10-29得票数 1
回答已采纳
云服务器
ICP备案
对象存储
即时通信 IM
云直播
腾讯云开发者
