private Sink sink()

in scorecard-client/src/main/java/org/apache/fineract/credit/scorecard/ProgressRequestBody.java [73:90]

• 15 lines of code
• 2 McCabe index (conditional complexity)

    private Sink sink(Sink sink) {
        return new ForwardingSink(sink) {

            long bytesWritten = 0L;
            long contentLength = 0L;

            @Override
            public void write(Buffer source, long byteCount) throws IOException {
                super.write(source, byteCount);
                if (contentLength == 0) {
                    contentLength = contentLength();
                }

                bytesWritten += byteCount;
                callback.onUploadProgress(bytesWritten, contentLength, bytesWritten == contentLength);
            }
        };
    }