public void newToggleTest_toggleStream_sizeNoneZero()

in src/integrationtests/java/com/aws/iot/integrationtests/edgeconnectorforkvs/videorecorder/VideoRecorderToggleAppPathTest.java [166:211]

• 35 lines of code
• 1 McCabe index (conditional complexity)

    public void newToggleTest_toggleStream_sizeNoneZero() throws InterruptedException, IOException {
        // Create recorders
        System.out.println("Test Init");
        this.initByteArray(true);
        final RecorderTest recorder1 = new RecorderTest(rec1ByteOut1, rec1ByteOut2, "recorder1");
        final RecorderTest recorder2 = new RecorderTest(rec2ByteOut1, rec2ByteOut2, "recorder2");
        Thread recordThread1 = new Thread(() -> recorder1.run());
        Thread recordThread2 = new Thread(() -> recorder2.run());

        // Start recording in their own threads
        System.out.println("Test Start");
        recordThread1.start();
        recordThread2.start();
        TimeUnit.SECONDS.sleep(this.TEST_IDLE_INTERVAL);

        // stop toggle
        System.out.println("stop toggle");
        recorder1.toggle(false);
        recorder2.toggle(false);
        resetByteArray(false);
        TimeUnit.SECONDS.sleep(this.TEST_IDLE_INTERVAL);
        resetByteArray(true);

        // start toggle
        System.out.println("start toggle");
        recorder1.toggle(true);
        recorder2.toggle(true);
        TimeUnit.SECONDS.sleep(this.TEST_IDLE_INTERVAL);

        // stop rec
        System.out.println("stop toggle");
        recorder1.toggle(false);
        recorder2.toggle(false);
        resetByteArray(false);

        // stop test
        System.out.println("stop test");
        recorder1.stop();
        recorder2.stop();
        rec1ByteOut1.close();
        rec1ByteOut2.close();
        rec2ByteOut1.close();
        rec2ByteOut2.close();
        this.initByteArray(false);
        System.out.println("Bye");
    }