public void flushBuffer()

in aws-serverless-java-container-core/src/main/java/com/amazonaws/serverless/proxy/internal/servlet/AwsHttpServletResponse.java [391:417]

• 19 lines of code
• 7 McCabe index (conditional complexity)

    public void flushBuffer() throws IOException {
        if (null != writer) {
            writer.flush();
        }
        String charset = characterEncoding;

        byte[] respBody = bodyOutputStream.toByteArray();

        // The content type is json but we have no encoding specified, according to the RFC (https://tools.ietf.org/html/rfc4627#section-3)
        // we should attempt to detect the encoding. However, since we are running in Lambda we shouldn't even consider
        // big endian systems and it's highly unlikely we'll have apps using UTF-16/32 we simply force UTF-8
        if (headers != null && headers.getFirst(HttpHeaders.CONTENT_TYPE) != null &&
                headers.getFirst(HttpHeaders.CONTENT_TYPE).toLowerCase(Locale.getDefault()).trim().equals(MediaType.APPLICATION_JSON) &&
                charset == null) {
            charset = "UTF-8";
        }

        // if at this point we are still null, we set the default
        if (charset == null) {
            charset = LambdaContainerHandler.getContainerConfig().getDefaultContentCharset();
        }

        responseBody = new String(respBody, charset);
        log.debug("Response buffer flushed with {} bytes, latch={}", responseBody.length(), writersCountDownLatch.getCount());
        isCommitted = true;
        writersCountDownLatch.countDown();
    }