Sha256: d6fb3eff5705ee4a8f75db1d5fdd07148452d9dbcb4704dd7f001b534875cc28
Contents?: true
Size: 605 Bytes
Versions: 14
Compression:
Stored size: 605 Bytes
Contents
function elementAtOrDefault(source, index, hasDefault, defaultValue) {
if (index < 0) { throw new ArgumentOutOfRangeError(); }
return new AnonymousObservable(function (o) {
var i = index;
return source.subscribe(function (x) {
if (i-- === 0) {
o.onNext(x);
o.onCompleted();
}
}, function (e) { o.onError(e); }, function () {
if (!hasDefault) {
o.onError(new ArgumentOutOfRangeError());
} else {
o.onNext(defaultValue);
o.onCompleted();
}
});
}, source);
}
Version data entries
14 entries across 7 versions & 1 rubygems