this.tarFile = tarFile

        boolean gzip = !tarFile.name.endsWith("tar")
        tarFile.withInputStream { inputStream ->
            TarArchiveInputStream tarInputStream = new TarArchiveInputStream(gzip ? new GZIPInputStream(inputStream) : inputStream, metadataCharset)
            for (TarArchiveEntry tarEntry = getNextEntry(tarInputStream); tarEntry != null; tarEntry = getNextEntry(tarInputStream)) {

        }
        tarOutput.close();
    }

    @Override
    public void unpack(DataSource input, DataTargetFactory targetFactory) throws IOException {
        TarArchiveInputStream tarInput = new TarArchiveInputStream(input.openInput());
        while (true) {
            TarArchiveEntry entry = tarInput.getNextEntry();
            if (entry == null) {
                break;
            }

        int signatureLength = IOUtils.readFully(inputStream, tarHeader);
        inputStream.reset();
        if (TarArchiveInputStream.matches(tarHeader, signatureLength)) {
            return;
        }

        if (signatureLength >= tarHeaderSize) {
            try (TarArchiveInputStream tais = new TarArchiveInputStream(new ByteArrayInputStream(tarHeader))) {
                TarArchiveEntry tarEntry = tais.getNextEntry();

        try (TarArchiveInputStream tarInput = new TarArchiveInputStream(input, ENCODING.name())) {
            return unpack(entity, tarInput, readOrigin);
        }
    }

    private UnpackResult unpack(CacheableEntity entity, TarArchiveInputStream tarInput, OriginReader readOriginAction) throws IOException {