public void onWritePossible()

in src/main/java/org/apache/sling/clam/http/internal/ClamEventsServlet.java [173:183]

• 11 lines of code
• 3 McCabe index (conditional complexity)

        public void onWritePossible() throws IOException {
            final ServletOutputStream outputStream = context.getResponse().getOutputStream();
            while (outputStream.isReady() && events.peek() != null) {
                final Event event = events.poll();
                @SuppressWarnings("java:S3457")
                final String data = String.format("event: %s\ndata: %s\n\n", event.getType(), event.getData());
                outputStream.write(data.getBytes(StandardCharsets.UTF_8));
                flushIfReady(outputStream);
            }
            flushIfReady(outputStream);
        }