admin管理员组文章数量:1328556
I have an Issue with timeout operator in subject.
my problem look like sample above, but I got all of source,
response: observable: 1 observable: 2
url: .ts
import { Subject, from,Observable } from 'rxjs';
import {timeout} from 'rxjs/operators';
const subject = new Subject();
subject.subscribe({
next: (v) => console.log(`observer: ${v}`),
error: (e) => console.log(`There is an Error ${e}`)
});
subject.pipe(timeout(2000));
const observable = new Observable( sub=> {
sub.next( 1);
setTimeout(()=> {
sub.next(2)
},5000)
})
observable.subscribe(subject);
I have an Issue with timeout operator in subject.
my problem look like sample above, but I got all of source,
response: observable: 1 observable: 2
url: https://stackblitz./edit/ou5yp1?file=index.ts
import { Subject, from,Observable } from 'rxjs';
import {timeout} from 'rxjs/operators';
const subject = new Subject();
subject.subscribe({
next: (v) => console.log(`observer: ${v}`),
error: (e) => console.log(`There is an Error ${e}`)
});
subject.pipe(timeout(2000));
const observable = new Observable( sub=> {
sub.next( 1);
setTimeout(()=> {
sub.next(2)
},5000)
})
observable.subscribe(subject);
Share
Improve this question
asked Aug 18, 2020 at 11:54
Omid MamandiOmid Mamandi
1131 gold badge2 silver badges7 bronze badges
1 Answer
Reset to default 5You have subscribed to wrong observable.
subject.pipe(timeout(2000));
The above line does not apply to subject itself, but instead returns a new observable which has 2 seconds timeout. So you should subscribe to this returned observable instead of subject itself. So your code should be:
subject.pipe(timeout(2000)).subscribe({
next: (v) => console.log(`observer: ${v}`),
error: (e) => console.log(`There is an Error ${e}`)
});
本文标签: javascripttimeout() operator not working in pipe Rxjs subjectStack Overflow
版权声明:本文标题:javascript - timeout() operator not working in pipe Rxjs subject - Stack Overflow 内容由网友自发贡献,该文观点仅代表作者本人, 转载请联系作者并注明出处:http://www.betaflare.com/web/1742250773a2440716.html, 本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,一经查实,本站将立刻删除。
发表评论