Category "rxjs5"

RxJS: takeUntil() Angular component's ngOnDestroy()

tl;dr: Basically I want to marry Angular's ngOnDestroy with the Rxjs takeUntil() operator. -- is that possible? I have an Angular component that opens several

When to use asObservable() in rxjs?

I am wondering what is the use of asObservable: As per docs: An observable sequence that hides the identity of the source sequence. But why would you

RxJs - lossy zip marble testing

Following this post I've decided to write a marble test for this operator. Here is a basic test: it('Test lossy zip', () => { const a = hot('a---a-

rxjs5 toPromise not working

In the following example toPromise does not work: https://jsfiddle.net/tossp/nmf9jg32/ My code: function getPostData() { return fetch('https://jsonplaceh

RxJs: Incrementally push stream of data to BehaviorSubject<[]>

Basically I'm trying to inflate BehaviorSubject<[]> with array of data which will be loaded in chunks. BehaviorSubject<[]> will be added with new c

How can I use RxJS to generate a requestAnimationFrame loop?

My goal is to create an animation loop à la requestAnimationFrame so that I could do something like this: animationObservable.subscribe(() => { /