Method downstreamRequest has a Cognitive Complexity of 23 (exceeds 5 allowed). Consider refactoring.

Open

    final void downstreamRequest(long n) {
        if (n < 0L) {
            throw new IllegalArgumentException("n >= 0 required but it was " + n);
        }
        if (n != 0L) {

• Read up
  Read up

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

File CachedObservable.java has 296 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 call has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public Subscriber<? super T> call(final Subscriber<? super T> child) {
        final AtomicLong requested = new AtomicLong();

        child.setProducer(new Producer() {

• Read up
  Read up

Method assertCapacity has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

        private boolean assertCapacity() {
            if (capacity == null) {
                return true;
            }

• Read up
  Read up

Method drain has 77 lines of code (exceeds 25 allowed). Consider refactoring.

Open

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

Method setup has 76 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @Setup
    public void setup() {
        scalar = Observable.just(1);
        one = Observable.unsafeCreate(new OnSubscribe<Integer>() {
            @Override

Method call has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public Subscriber<? super T> call(final Subscriber<? super R> child) {
        final R initialValue = initialValueFactory.call();

        if (initialValue == NO_INITIAL_VALUE) {

• Read up
  Read up

Method request has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

        @Override
        public void request(long n) {
            if (n >= 0) {
                for (;;) {
                    long r = get();

• Read up
  Read up

Method onNext has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public void onNext(T t) {
        if (terminated) {
            return;
        }

• Read up
  Read up

File BlockingObservable.java has 286 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 drain has 70 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        void drain() {
            boolean localInnerActive;
            long localRequested;
            Throwable localError;
            synchronized (this) {

Method drain has 70 lines of code (exceeds 25 allowed). Consider refactoring.

Open

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

File OnSubscribeGroupJoin.java has 283 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 call has 69 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @Override
    public Subscriber<? super T> call(final Subscriber<? super T> child) {
        final ProducerArbiter pa = new ProducerArbiter();

        final SerialSubscription serial = new SerialSubscription();

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

Open

        void drain() {
            AtomicInteger dw = drainWip;
            if (dw.getAndIncrement() != 0) {
                return;
            }

• Read up
  Read up

Method call has a Cognitive Complexity of 20 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public Subscriber<? super T> call(final Subscriber<? super T> child) {
        final ProducerArbiter pa = new ProducerArbiter();

        final SerialSubscription serial = new SerialSubscription();

• Read up
  Read up

Method manageRequests has 68 lines of code (exceeds 25 allowed). Consider refactoring.

Open

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

Method drain has 67 lines of code (exceeds 25 allowed). Consider refactoring.

Open

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

Method replay has 67 lines of code (exceeds 25 allowed). Consider refactoring.

Open

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