return new FramedSnappyCompressorOutputStream(super.openOutput());
            }
        });
    }

    @Override
    public void unpack(DataSource input, DataTargetFactory targetFactory) throws IOException {
        delegate.unpack(new DelegatingDataSource(input) {
            @Override
            public InputStream openInput() throws IOException {

            tarOutput.putNextEntry(entry);
            PackerUtils.packEntry(input, tarOutput, buffer);
        }
        tarOutput.close();
    }

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

            PackerUtils.packEntry(input, zipOutput, buffer);
            zipOutput.closeEntry();
        }
        zipOutput.close();
    }

    @Override
    public void unpack(DataSource input, DataTargetFactory targetFactory) throws IOException {
        ZipInputStream zipInput = new ZipInputStream(input.openInput());
        while (true) {
            ZipEntry entry = zipInput.getNextEntry();
            if (entry == null) {