public void run()

in common/src/main/java/org/apache/rocketmq/schema/registry/common/utils/CommonUtil.java [201:228]

• 25 lines of code
• 5 McCabe index (conditional complexity)

        public void run() {

            InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
            BufferedReader br = new BufferedReader(inputStreamReader);
            try {
                String line;
                StringBuilder sb = new StringBuilder();
                while ((line = br.readLine()) != null) {
                    sb.append(line);
                }
                output = sb.toString();
            } catch (Throwable e) {
                log.error("Read from file error", e);
            } finally {
                try {
                    br.close();

                } catch (IOException ioException) {
                    log.error("", ioException);
                }
                try {
                    inputStreamReader.close();

                } catch (IOException ioException) {
                    log.error("", ioException);
                }
            }
        }