The following issues were found
src/test/java/io/reactivex/rxjava3/tck/SwitchMapDelayErrorTckTest.java
1 issues
Line: 28
@Override
public Publisher<Long> createPublisher(long elements) {
return
Flowable.just(1).switchMapDelayError(Functions.justFunction(
Flowable.fromIterable(iterate(elements)))
)
;
}
}
Reported by PMD.
src/test/java/io/reactivex/rxjava3/tck/SingleFlatMapFlowableTckTest.java
1 issues
Line: 19
import org.reactivestreams.Publisher;
import org.testng.annotations.Test;
import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.functions.Function;
@Test
public class SingleFlatMapFlowableTckTest extends BaseTck<Integer> {
Reported by PMD.
src/test/java/io/reactivex/rxjava3/tck/SequenceEqualTckTest.java
1 issues
Line: 27
@Override
public Publisher<Boolean> createPublisher(final long elements) {
return
Flowable.sequenceEqual(
Flowable.range(1, 1000),
Flowable.range(1, 1001))
.toFlowable()
;
}
Reported by PMD.
src/test/java/io/reactivex/rxjava3/tck/RepeatTckTest.java
1 issues
Line: 26
@Override
public Publisher<Integer> createPublisher(long elements) {
return Flowable.just(1).repeat(elements);
}
}
Reported by PMD.
src/test/java/io/reactivex/rxjava3/tck/MaybeFlatMapPublisherTckTest.java
1 issues
Line: 19
import org.reactivestreams.Publisher;
import org.testng.annotations.Test;
import io.reactivex.rxjava3.core.*;
import io.reactivex.rxjava3.functions.Function;
@Test
public class MaybeFlatMapPublisherTckTest extends BaseTck<Integer> {
Reported by PMD.
src/test/java/io/reactivex/rxjava3/tck/IntervalRangeTckTest.java
1 issues
Line: 29
@Override
public Publisher<Long> createPublisher(long elements) {
return
Flowable.intervalRange(0, elements, 0, 1, TimeUnit.MILLISECONDS)
.onBackpressureBuffer()
;
}
}
Reported by PMD.
src/test/java/io/reactivex/rxjava3/tck/CreateTckTest.java
1 issues
Line: 19
import org.reactivestreams.Publisher;
import org.testng.annotations.Test;
import io.reactivex.rxjava3.core.*;
@Test
public class CreateTckTest extends BaseTck<Long> {
@Override
Reported by PMD.
src/test/java/io/reactivex/rxjava3/tck/ConcatWithSingleTckTest.java
1 issues
Line: 19
import org.reactivestreams.Publisher;
import org.testng.annotations.Test;
import io.reactivex.rxjava3.core.*;
@Test
public class ConcatWithSingleTckTest extends BaseTck<Integer> {
@Override
Reported by PMD.
src/test/java/io/reactivex/rxjava3/tck/ConcatWithMaybeTckTest.java
1 issues
Line: 19
import org.reactivestreams.Publisher;
import org.testng.annotations.Test;
import io.reactivex.rxjava3.core.*;
@Test
public class ConcatWithMaybeTckTest extends BaseTck<Integer> {
@Override
Reported by PMD.
src/test/java/io/reactivex/rxjava3/tck/ConcatWithMaybeEmptyTckTest.java
1 issues
Line: 19
import org.reactivestreams.Publisher;
import org.testng.annotations.Test;
import io.reactivex.rxjava3.core.*;
@Test
public class ConcatWithMaybeEmptyTckTest extends BaseTck<Integer> {
@Override
Reported by PMD.