Rx.Observable.jortSortUntil(other)
Ⓢ
The jortSort
method checks if your inputs are sorted until another Observable sequence fires.
See http://jort.technology/ for full details.
Arguments
other
(Observable
): The Observable sequence which will cause the termination of the sequence.
Returns
(Observable
): An observable which has a single value of true
if sorted, else false
.
Example
var just = Rx.helpers.just;
// Sorted
var source = Rx.Observable.of(1,2,3,4)
.flatMap(function (x) {
return Rx.Observable.timer(1000).map(just(x));
})
.jortSortUntil(Rx.Observable.timer(3000));
var subscription = source.subscribe(
function (x) { console.log('Next: %s', x); },
function (e) { console.log('Error: %s', e); },
function ( ) { console.log('Completed'); }
);
// => Next: true
// => Completed
// Non sorted
var source = Rx.Observable.of(3,1,2,4)
.flatMap(function (x) {
return Rx.Observable.timer(1000).map(just(x));
})
.jortSortUntil(Rx.Observable.timer(3000));
var subscription = source.subscribe(
function (x) { console.log('Next: %s', x); },
function (e) { console.log('Error: %s', e); },
function ( ) { console.log('Completed'); }
);
// => Next: false
// => Completed
Location
File:
Dist:
Prerequisites:
Unit Tests: