diff --git a/src/main/java/io/reactivex/rxjava3/core/Single.java b/src/main/java/io/reactivex/rxjava3/core/Single.java index 0541ce8657..f915bdc5b2 100644 --- a/src/main/java/io/reactivex/rxjava3/core/Single.java +++ b/src/main/java/io/reactivex/rxjava3/core/Single.java @@ -1387,22 +1387,22 @@ public static Single timer(long delay, @NonNull TimeUnit unit, @NonNull Sc * *
*
Scheduler:
- *
{@code equals} does not operate by default on a particular {@link Scheduler}.
+ *
{@code sequenceEqual} does not operate by default on a particular {@link Scheduler}.
*
* @param the common value type - * @param first the first {@code SingleSource} instance - * @param second the second {@code SingleSource} instance + * @param source1 the first {@code SingleSource} instance + * @param source2 the second {@code SingleSource} instance * @return the new {@code Single} instance - * @throws NullPointerException if {@code first} or {@code second} is {@code null} + * @throws NullPointerException if {@code source1} or {@code source2} is {@code null} * @since 2.0 */ @CheckReturnValue @NonNull @SchedulerSupport(SchedulerSupport.NONE) - public static Single equals(@NonNull SingleSource first, @NonNull SingleSource second) { // NOPMD - Objects.requireNonNull(first, "first is null"); - Objects.requireNonNull(second, "second is null"); - return RxJavaPlugins.onAssembly(new SingleEquals<>(first, second)); + public static Single sequenceEqual(@NonNull SingleSource source1, @NonNull SingleSource source2) { // NOPMD + Objects.requireNonNull(source1, "source1 is null"); + Objects.requireNonNull(source2, "source2 is null"); + return RxJavaPlugins.onAssembly(new SingleEquals<>(source1, source2)); } /** diff --git a/src/test/java/io/reactivex/rxjava3/internal/operators/single/SingleEqualsTest.java b/src/test/java/io/reactivex/rxjava3/internal/operators/single/SingleEqualsTest.java index c664784869..6c1bf14f30 100644 --- a/src/test/java/io/reactivex/rxjava3/internal/operators/single/SingleEqualsTest.java +++ b/src/test/java/io/reactivex/rxjava3/internal/operators/single/SingleEqualsTest.java @@ -28,7 +28,7 @@ public class SingleEqualsTest extends RxJavaTest { public void bothError() { List errors = TestHelper.trackPluginErrors(); try { - Single.equals(Single.error(new TestException("One")), Single.error(new TestException("Two"))) + Single.sequenceEqual(Single.error(new TestException("One")), Single.error(new TestException("Two"))) .to(TestHelper.testConsumer()) .assertFailureAndMessage(TestException.class, "One"); diff --git a/src/test/java/io/reactivex/rxjava3/internal/operators/single/SingleMiscTest.java b/src/test/java/io/reactivex/rxjava3/internal/operators/single/SingleMiscTest.java index ca2ccacdc2..dad1322b22 100644 --- a/src/test/java/io/reactivex/rxjava3/internal/operators/single/SingleMiscTest.java +++ b/src/test/java/io/reactivex/rxjava3/internal/operators/single/SingleMiscTest.java @@ -280,11 +280,11 @@ public void toObservable() { @Test public void equals() { - Single.equals(Single.just(1), Single.just(1).hide()) + Single.sequenceEqual(Single.just(1), Single.just(1).hide()) .test() .assertResult(true); - Single.equals(Single.just(1), Single.just(2)) + Single.sequenceEqual(Single.just(1), Single.just(2)) .test() .assertResult(false); }