*/

package org.gradle.caching.internal.tasks;

import java.io.IOException;
import java.io.InputStream;

public abstract class DelegatingDataSource implements DataSource {
    private final DataSource delegate;

    public DelegatingDataSource(DataSource delegate) {
        this.delegate = delegate;
    }

    @Override
    public InputStream openInput() throws IOException {

            }
        });
    }

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

            }
        });
    }

    @Override
    public void unpack(DataSource input, DataTargetFactory targetFactory) throws IOException {
        delegate.unpack(new DelegatingDataSource(input) {
            @Override
            public InputStream openInput() throws IOException {
                return new SnappyFramedInputStream(super.openInput(), true);
            }
        }, targetFactory);

            }
        });
    }

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

            }
        });
    }

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