private void recreateInnerStream()

in S3HtsjdkPlugin/src/main/java/com/epam/cmbi/s3/S3SeekableStream.java [62:75]

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

    private void recreateInnerStream() {
        if (null != currentDataStream) {
            try {
                currentDataStream.close();
            } catch (IOException e) {
                throw new RuntimeIOException(e.getMessage() + "failed to close the data stream", e);
            }
        }

        final InputStream fileOnOffsetDataStream =
                new S3ParallelStream(s3Source, offset, length(), factory);
        this.currentDataStream = new CountingWithSkipInputStream(fileOnOffsetDataStream);
        log.debug("A new data stream was launched on offset = ", offset);
    }