Sha256: af13806aec99c70200aae85460b8c8ce2bd10a2b27e66fb9fa71f2819c1e9897
Contents?: true
Size: 1.21 KB
Versions: 14
Compression:
Stored size: 1.21 KB
Contents
/**
* Filters the elements of an observable sequence based on a predicate by incorporating the element's index.
*
* @example
* var res = source.where(function (value) { return value < 10; });
* var res = source.where(function (value, index) { return value < 10 || index < 10; });
* @param {Function} predicate A function to test each source element for a condition; the second parameter of the function represents the index of the source element.
* @param {Any} [thisArg] Object to use as this when executing callback.
* @returns {Observable} An observable sequence that contains elements from the input sequence that satisfy the condition.
*/
observableProto.where = observableProto.filter = function (predicate, thisArg) {
var source = this;
predicate = bindCallback(predicate, thisArg, 3);
return new AnonymousObservable(function (o) {
var count = 0;
return source.subscribe(function (value) {
try {
var shouldRun = predicate(value, count++, source);
} catch (e) {
o.onError(e);
return;
}
shouldRun && o.onNext(value);
}, function (e) { o.onError(e); }, function () { o.onCompleted(); });
}, source);
};
Version data entries
14 entries across 7 versions & 1 rubygems