return StringUtils.join(newInputs, ",");
            }
            return StringUtils.join(newInputs, ",") + "=>" + StringUtils.join(newOutputs, ",");
        }
        if (Arrays.equals(inputs, outputs)) {
            return StringUtils.join(inputs, ",");
        }
        return StringUtils.join(inputs, ",") + "=>" + StringUtils.join(outputs, ",");
    }

        final String jwtClaim = "{\"sub\":\"user123\",\"name\":\"John Doe\",\"email\":\"john@example.com\"}";
        final Map<String, Object> attributes = new HashMap<>();

        authenticator.parseJwtClaim(jwtClaim, attributes);

        assertEquals("user123", attributes.get("sub"));
        assertEquals("John Doe", attributes.get("name"));
        assertEquals("john@example.com", attributes.get("email"));
    }

    @Test

        JobProcess jobProcess = new JobProcess(mockProcess, 100, callback);
        InputStreamThread thread = jobProcess.getInputStreamThread();

        thread.start();
        thread.join(1000);

        assertEquals(2, callbackResults.size());
        assertEquals("integration test", callbackResults.get(0));
        assertEquals("second line", callbackResults.get(1));

        if (r.exitCode != 0) {
            throw new AssertionError(String.join(" ", cmd) + " failed: " + r);
        }
    }

    private static String stdout(String... cmd) throws IOException, InterruptedException {
        ExecResult r = exec(cmd);
        if (r.exitCode != 0) {
            throw new AssertionError(String.join(" ", cmd) + " failed: " + r);
        }
        return r.stdout;
    }

            return accessor.getBinaryCompatibility() == BinaryCompatibility.ACCESSORS_KEPT;
        });
        if (!keptAccessors.isEmpty()) {
            String formattedLeft = CollectionUtils.join("\n", keptAccessors.keySet());
            throw new RuntimeException("The following accessors were upgraded, but didn't match any removed/changed method:\n\n" + formattedLeft);
        }

        // Start all threads
        for (Thread thread : threads) {
            thread.start();
        }

        // Wait for all threads to complete
        for (Thread thread : threads) {
            thread.join();
        }

        // Verify no exceptions occurred
        for (int i = 0; i < threadCount; i++) {
            assertNull(exceptions[i], "Thread " + i + " threw exception");

     *
     * @return The stopword as a string.
     */
    public String toLineString() {
        if (isUpdated()) {
            return StringUtils.join(newInput);
        }
        return StringUtils.join(input);
    }

        value = "\"John Doe\",\"Software Engineer\",\"john******@****.***\",\"Loves \"\"coding\"\" and coffee\"";
        result = KuromojiCSVUtil.parse(value);
        assertEquals(4, result.length);
        assertEquals("John Doe", result[0]);
        assertEquals("Software Engineer", result[1]);
        assertEquals("john******@****.***", result[2]);

     * @return the string representation of this item
     */
    public String toLineString() {
        if (isUpdated()) {
            return StringUtils.join(newInput);
        }
        return StringUtils.join(input);
    }

            }
        });

        // Start both threads
        threads[0].start();
        threads[1].start();

        // Wait for completion
        threads[0].join();
        threads[1].join();

        // Verify no exceptions occurred (the main goal is no ConcurrentModificationException)
        assertNull(exceptions[0], "Add thread threw exception");