3.x: Cover changes of #7196

Author: akarnokd

src/main/java/io/reactivex/rxjava3/internal/operators/maybe/MaybeZipArray.java

@@ -13,7 +13,6 @@
 
 package io.reactivex.rxjava3.internal.operators.maybe;
 
-import java.util.Arrays;
 import java.util.Objects;
 import java.util.concurrent.atomic.*;
 

src/main/java/io/reactivex/rxjava3/internal/operators/single/SingleZipArray.java

@@ -13,7 +13,6 @@
 
 package io.reactivex.rxjava3.internal.operators.single;
 
-import java.util.Arrays;
 import java.util.Objects;
 import java.util.concurrent.atomic.*;
 

src/test/java/io/reactivex/rxjava3/internal/operators/maybe/MaybeZipArrayTest.java

@@ -221,4 +221,21 @@ public void oneSourceOnly() {
         .test()
         .assertResult(Arrays.asList(1));
     }
+
+    @Test
+    public void onSuccessAfterDispose() {
+        AtomicReference<MaybeObserver<? super Integer>> emitter = new AtomicReference<>();
+
+        TestObserver<List<Object>> to = Maybe.zipArray(Arrays::asList,
+                (MaybeSource<Integer>)o -> emitter.set(o), Maybe.<Integer>never())
+        .test();
+
+        emitter.get().onSubscribe(Disposable.empty());
+
+        to.dispose();
+
+        emitter.get().onSuccess(1);
+
+        to.assertEmpty();
+    }
 }

src/test/java/io/reactivex/rxjava3/internal/operators/single/SingleZipArrayTest.java

@@ -16,10 +16,12 @@
 import static org.junit.Assert.*;
 
 import java.util.*;
+import java.util.concurrent.atomic.AtomicReference;
 
 import org.junit.Test;
 
 import io.reactivex.rxjava3.core.*;
+import io.reactivex.rxjava3.disposables.Disposable;
 import io.reactivex.rxjava3.exceptions.TestException;
 import io.reactivex.rxjava3.functions.*;
 import io.reactivex.rxjava3.internal.functions.Functions;
@@ -213,4 +215,21 @@ public void bothSucceed() {
         .test()
         .assertResult(Arrays.asList(1, 2));
     }
+
+    @Test
+    public void onSuccessAfterDispose() {
+        AtomicReference<SingleObserver<? super Integer>> emitter = new AtomicReference<>();
+
+        TestObserver<List<Object>> to = Single.zipArray(Arrays::asList,
+                (SingleSource<Integer>)o -> emitter.set(o), Single.<Integer>never())
+        .test();
+
+        emitter.get().onSubscribe(Disposable.empty());
+
+        to.dispose();
+
+        emitter.get().onSuccess(1);
+
+        to.assertEmpty();
+    }
 }