app: harden mirroring lifecycle and state

1 files changed, 12 insertions, 1 deletions

diff --git a/app/src/test/java/invalid/lena/scrcpy/AudioStreamTest.java b/app/src/test/java/invalid/lena/scrcpy/AudioStreamTest.java
index 076d27c..005a2e3 100644
--- a/app/src/test/java/invalid/lena/scrcpy/AudioStreamTest.java
+++ b/app/src/test/java/invalid/lena/scrcpy/AudioStreamTest.java
@@ -11,6 +11,7 @@ import java.io.DataOutputStream;
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.atomic.AtomicInteger;
 
 public class AudioStreamTest {
 
@@ -116,8 +117,18 @@ public class AudioStreamTest {
     public void errorCodecDoesNotStart() throws Exception {
         byte[] bytes = fourcc(1);
         RecordingFrames sink = new RecordingFrames();
-        new AudioStream(new ByteArrayInputStream(bytes), sink).run();
+        AtomicInteger fatal = new AtomicInteger();
+        new AudioStream(new ByteArrayInputStream(bytes), sink, fatal::incrementAndGet).run();
         assertEquals(0, sink.starts);
         assertEquals(0, sink.feeds.size());
+        assertEquals(1, fatal.get());
+    }
+
+    @Test
+    public void disabledCodecIsNotFatal() throws Exception {
+        AtomicInteger fatal = new AtomicInteger();
+        new AudioStream(new ByteArrayInputStream(fourcc(0)),
+                new RecordingFrames(), fatal::incrementAndGet).run();
+        assertEquals(0, fatal.get());
     }
 }