File OperatorGroupByEvicting.java has 470 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/**
 * Copyright 2018 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 call has a Cognitive Complexity of 47 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public void call(final CompletableSubscriber s) {
        final CompositeSubscription set = new CompositeSubscription();

        s.onSubscribe(set);

• Read up
  Read up

BlockingObservable has 50 methods (exceeds 20 allowed). Consider refactoring.

Open

public final class BlockingObservable<T> {

    private final Observable<? extends T> o;

    /** Constant to indicate the onStart method should be called. */

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

Open

        @Override
        public void drain(ReplayProducer<T> rp) {
            if (rp.getAndIncrement() != 0) {
                return;
            }

• Read up
  Read up

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

Open

        @Override
        public void drain(ReplayProducer<T> rp) {
            if (rp.getAndIncrement() != 0) {
                return;
            }

• Read up
  Read up

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

Open

        @Override
        public void drain(ReplayProducer<T> rp) {
            if (rp.getAndIncrement() != 0) {
                return;
            }

• Read up
  Read up

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

Open

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

• Read up
  Read up

File OperatorWindowWithTime.java has 427 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. You may obtain a copy of

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

Open

        @Override
        public final void replay(InnerProducer<T> output) {
            synchronized (output) {
                if (output.emitting) {
                    output.missed = true;

• Read up
  Read up

File AsyncOnSubscribe.java has 418 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.

File OperatorPublish.java has 408 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. You may obtain a copy of

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

Open

    public void drain() {
        boolean term;
        synchronized (this) {
            if (emitting) {
                return;

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

File OnSubscribeCreate.java has 393 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 createStacktrace has a Cognitive Complexity of 36 (exceeds 5 allowed). Consider refactoring.

Open

    static String createStacktrace() {
        StackTraceElement[] stacktraceElements = Thread.currentThread().getStackTrace();

        StringBuilder sb = new StringBuilder("Assembly trace:");

• Read up
  Read up

Method call has 134 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @Override
    public void call(final Subscriber<? super T> child) {

        // when true is a marker to say we are ready to resubscribe to source
        final AtomicBoolean resumeBoundary = new AtomicBoolean(true);

Method manageRequests has a Cognitive Complexity of 34 (exceeds 5 allowed). Consider refactoring.

Open

        void manageRequests(InnerProducer<T> inner) {
            // if the upstream has completed, no more requesting is possible
            if (isUnsubscribed()) {
                return;
            }

• Read up
  Read up

Method checkTerminated has a Cognitive Complexity of 34 (exceeds 5 allowed). Consider refactoring.

Open

    boolean checkTerminated(boolean d, boolean empty) {
        if (d) {
            if (delayError) {
                if (empty) {
                    PublishProducer<T>[] a = terminate();

• Read up
  Read up

TestSubscriber has 38 methods (exceeds 20 allowed). Consider refactoring.

Open

public class TestSubscriber<T> extends Subscriber<T> {

    private final Observer<T> delegate;

    private final List<T> values;