Completable has 191 methods (exceeds 20 allowed). Consider refactoring.

Open

public class Completable {
    /** The actual subscription action. */
    private final OnSubscribe onSubscribe;

    /**

File Completable.java has 1377 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/**
 * Copyright 2014 Netflix, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.

Method emitLoop has a Cognitive Complexity of 165 (exceeds 5 allowed). Consider refactoring.

Open

        void emitLoop() {
            boolean skipFinal = false;
            try {
                final Subscriber<? super T> child = this.child;
                for (;;) {

• Read up
  Read up

Single has 123 methods (exceeds 20 allowed). Consider refactoring.

Open

public class Single<T> {

    final OnSubscribe<T> onSubscribe;

    /**

File OperatorReplay.java has 874 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/**
 * Copyright 2014 Netflix, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.

File ReplaySubject.java has 795 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/**
 * Copyright 2014 Netflix, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.

RxJavaHooks has 88 methods (exceeds 20 allowed). Consider refactoring.

Open

public final class RxJavaHooks {
    /**
     * Prevents changing the hook callbacks when set to true.
     */
    /* test */ static volatile boolean lockdown;

File OperatorMerge.java has 654 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/**
 * Copyright 2014 Netflix, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.

File Single.java has 642 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/**
 * Copyright 2015 Netflix, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in
 * compliance with the License. You may obtain a copy of the License at

Method emitLoop has a Cognitive Complexity of 69 (exceeds 5 allowed). Consider refactoring.

Open

    void emitLoop() {
        final Subscriber<? super T> c = child;

        long toRequest = 0L;
        Producer requestFrom = null;

• Read up
  Read up

Method drain has a Cognitive Complexity of 68 (exceeds 5 allowed). Consider refactoring.

Open

        void drain() {
            if (wip.getAndIncrement() != 0) {
                return;
            }

• Read up
  Read up

Method drain has a Cognitive Complexity of 63 (exceeds 5 allowed). Consider refactoring.

Open

        void drain() {
            if (wip.getAndIncrement() != 0) {
                return;
            }

• Read up
  Read up

File RxJavaHooks.java has 574 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/**
 * Copyright 2016 Netflix, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.

Method drain has a Cognitive Complexity of 58 (exceeds 5 allowed). Consider refactoring.

Open

        void drain() {
            if (wip.getAndIncrement() != 0) {
                return;
            }

• Read up
  Read up

Method dispatch has a Cognitive Complexity of 57 (exceeds 5 allowed). Consider refactoring.

Open

        void dispatch() {
            // standard construct of emitter loop (blocking)
            // if there is an emission going on, indicate that more work needs to be done
            // the exact nature of this work needs to be determined from other data structures
            synchronized (this) {

• Read up
  Read up

Method replay has a Cognitive Complexity of 57 (exceeds 5 allowed). Consider refactoring.

Open

        public void replay() {
            // make sure there is only a single thread emitting
            synchronized (this) {
                if (emitting) {
                    missed = true;

• Read up
  Read up

Method tick has a Cognitive Complexity of 55 (exceeds 5 allowed). Consider refactoring.

Open

        @SuppressWarnings("unchecked")
        void tick() {
            final Object[] subscribers = this.subscribers;
            if (subscribers == null) {
                // nothing yet to do (initial request from Producer)

• Read up
  Read up

Method drain has a Cognitive Complexity of 53 (exceeds 5 allowed). Consider refactoring.

Open

        void drain() {
            if (wip.getAndIncrement() != 0) {
                return;
            }
            int missed = 1;

• Read up
  Read up

Method emitLoop has 186 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        void emitLoop() {
            boolean skipFinal = false;
            try {
                final Subscriber<? super T> child = this.child;
                for (;;) {

File OperatorGroupBy.java has 476 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/**
 * Copyright 2014 Netflix, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.