public void run()

in maven-surefire-common/src/main/java/org/apache/maven/plugin/surefire/extensions/StreamFeeder.java [68:103]

35 lines of code
13 McCabe index (conditional complexity)


    public void run() {
        try (CommandEncoder encoder = new CommandEncoder(channel)) {
            for (Command cmd; (cmd = commandReader.readNextCommand()) != null; ) {
                if (!disabled) {
                    switch (cmd.getCommandType()) {
                        case RUN_CLASS:
                            encoder.sendRunClass(cmd.getData());
                            break;
                        case TEST_SET_FINISHED:
                            encoder.sendTestSetFinished();
                            break;
                        case SKIP_SINCE_NEXT_TEST:
                            encoder.sendSkipSinceNextTest();
                            break;
                        case SHUTDOWN:
                            encoder.sendShutdown(cmd.getData());
                            break;
                        case NOOP:
                            encoder.sendNoop();
                            break;
                        case BYE_ACK:
                            encoder.sendByeAck();
                            break;
                        default:
                            logger.error("Unknown enum " + cmd.getCommandType().name());
                    }
                }
            }
        } catch (ClosedChannelException e) {
            // closed externally
        } catch (IOException | NonWritableChannelException e) {
            exception = e.getCause() == null ? e : e.getCause();
        } catch (IllegalArgumentException e) {
            logger.error(e.getLocalizedMessage());
        }
    }