Reactive-Extensions/RxJS

View on GitHub

Showing 2,890 of 2,890 total issues

Function exports has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

module.exports = function (source, count, skip) {
+count || (count = 0);
Math.abs(count) === Infinity && (count = 0);
if (count <= 0) { throw new ArgumentOutOfRangeError(); }
skip == null && (skip = count);
Severity: Minor
Found in src/modular/observable/windowcount.js - About 25 mins to fix

Function SumObserver has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

var SumObserver = (function (__super__) {
inherits(SumObserver, __super__);
 
function SumObserver(o, fn, s) {
this._o = o;
Severity: Minor
Found in src/core/linq/observable/sum.js - About 25 mins to fix

Function LastIndexOfObserver has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

var LastIndexOfObserver = (function (__super__) {
inherits(LastIndexOfObserver, __super__);
function LastIndexOfObserver(o, e, n) {
this._o = o;
this._e = e;
Severity: Minor
Found in src/core/linq/observable/lastindexof.js - About 25 mins to fix

Function next has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

ReduceObserver.prototype.next = function (x) {
!this._hv && (this._hv = true);
if (this._ha) {
this._a = tryCatch(this._fn)(this._a, x, this._i, this._p);
} else {
Severity: Minor
Found in src/modular/observable/reduce.js - About 25 mins to fix

Function MergeDelayErrorObserver has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

var MergeDelayErrorObserver = (function(__super__) {
inherits(MergeDelayErrorObserver, __super__);
function MergeDelayErrorObserver(group, state) {
this._group = group;
this._state = state;
Severity: Minor
Found in src/core/linq/observable/mergedelayerror.js - About 25 mins to fix

Function RepeatEnumerable has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

var RepeatEnumerable = (function (__super__) {
inherits(RepeatEnumerable, __super__);
function RepeatEnumerable(v, c) {
this.v = v;
this.c = c == null ? -1 : c;
Severity: Minor
Found in src/core/enumerable.js - About 25 mins to fix

Function DefaultScheduler has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

var DefaultScheduler = (function (__super__) {
inherits(DefaultScheduler, __super__);
function DefaultScheduler() {
__super__.call(this);
}
Severity: Minor
Found in src/core/concurrency/defaultscheduler.js - About 25 mins to fix

Function ofObjectChanges has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

Observable.ofObjectChanges = function(obj) {
if (obj == null) { throw new TypeError('object must not be null or undefined.'); }
if (typeof Object.observe !== 'function' && typeof Object.unobserve !== 'function') { throw new TypeError('Object.observe is not supported on your platform') }
return new AnonymousObservable(function(observer) {
function observerFn(changes) {
Severity: Minor
Found in src/core/linq/observable/ofobjectchanges.js - About 25 mins to fix

Function invokeRecImmediate has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

function invokeRecImmediate(scheduler, pair) {
var state = pair[0], action = pair[1], group = new CompositeDisposable();
action(state, innerAction);
return group;
 
 
Severity: Minor
Found in src/modular/scheduler.js - About 25 mins to fix

Function invokeRecDate has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

function invokeRecDate(scheduler, pair) {
var state = pair[0], action = pair[1], group = new CompositeDisposable();
action(state, innerAction);
return group;
 
 
Severity: Minor
Found in src/modular/scheduler.js - About 25 mins to fix

Function createEventListener has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

function createEventListener (el, eventName, handler) {
var disposables = new CompositeDisposable();
 
// Asume NodeList or HTMLCollection
var elemToString = Object.prototype.toString.call(el);
Severity: Minor
Found in src/core/linq/observable/fromevent.js - About 25 mins to fix

Function DistinctObserver has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

var DistinctObserver = (function (__super__) {
inherits(DistinctObserver, __super__);
function DistinctObserver(o, keyFn, cmpFn) {
this._o = o;
this._keyFn = keyFn;
Severity: Minor
Found in src/core/linq/observable/distinct.js - About 25 mins to fix

Function SkipLastWithTimeObserver has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

var SkipLastWithTimeObserver = (function (__super__) {
inherits(SkipLastWithTimeObserver, __super__);
 
function SkipLastWithTimeObserver(o, p) {
this._o = o;
Severity: Minor
Found in src/core/linq/observable/skiplastwithtime.js - About 25 mins to fix

Function ofArrayChanges has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

Observable.ofArrayChanges = function(array) {
if (!Array.isArray(array)) { throw new TypeError('Array.observe only accepts arrays.'); }
if (typeof Array.observe !== 'function' && typeof Array.unobserve !== 'function') { throw new TypeError('Array.observe is not supported on your platform') }
return new AnonymousObservable(function(observer) {
function observerFn(changes) {
Severity: Minor
Found in src/core/linq/observable/ofarraychanges.js - About 25 mins to fix

Function StopAndWaitObservable has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

var StopAndWaitObservable = (function (__super__) {
inherits(StopAndWaitObservable, __super__);
function StopAndWaitObservable (source) {
__super__.call(this);
this.source = source;
Severity: Minor
Found in src/core/backpressure/stopandwait.js - About 25 mins to fix

Function SkipWhileObserver has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

var SkipWhileObserver = (function (__super__) {
inherits(SkipWhileObserver, __super__);
 
function SkipWhileObserver(o, p) {
this._o = o;
Severity: Minor
Found in src/core/linq/observable/skipwhile.js - About 25 mins to fix

Function amb has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

Observable.amb = function () {
var acc = observableNever(), items;
if (Array.isArray(arguments[0])) {
items = arguments[0];
} else {
Severity: Minor
Found in src/core/linq/observable/amb.js - About 25 mins to fix

Function next has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

FirstObserver.prototype.next = function (x) {
if (this._obj.predicate) {
var res = tryCatch(this._obj.predicate)(x, this._i++, this._s);
if (res === errorObj) { return this._o.onError(res.e); }
if (Boolean(res)) {
Severity: Minor
Found in src/modular/observable/first.js - About 25 mins to fix

Function ExpandObservable has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

var ExpandObservable = (function(__super__) {
inherits(ExpandObservable, __super__);
function ExpandObservable(source, fn, scheduler) {
this.source = source;
this._fn = fn;
Severity: Minor
Found in src/core/linq/observable/expand.js - About 25 mins to fix

Function SliceObserver has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
Open

var SliceObserver = (function (__super__) {
inherits(SliceObserver, __super__);
 
function SliceObserver(o, b, e) {
this._o = o;
Severity: Minor
Found in src/core/linq/observable/slice.js - About 25 mins to fix
Severity
Category
Status
Source
Language