CODEWITHSUNDEEP
rxjs
Jongz Puangput
Jongz Puangput

Reputation: 5637

rxjs takeuntil, check until observable source is valid

After searching for hours... most of example is like this...

var source = Rx.Observable.timer(0, 1000)
    .takeUntil(Rx.Observable.timer(5000));

var subscription = source.subscribe(
    function (x) { console.log('Next: ' + x); },
    function (err) { console.log('Error: ' + err); },
    function () { console.log('Completed'); })

Result

Next: 0
Next: 1
Next: 2
Next: 3
Next: 4
Completed

but, I wan to know is it possible to check from source value not another observable object.. something like this..

var source = Rx.Observable.timer(0, 1000)
    .takeUntil((result) => result == 5);

Upvotes: 1

Views: 5051

Answers (1)

kit
kit

Reputation: 4920

I guess what you are looking for is takeWhile

var source = Rx.Observable.timer(0, 1000)
    .takeWhile((result) => result < 5);

source.subscribe(
    (val) => console.log(val),
    (err) => console.log(err),
    () => console.log('complete')
);

Upvotes: 3

Related Questions