*/

package org.gradle.internal.resource;

import org.gradle.api.resources.ResourceException;

import java.io.InputStream;

/**
 * Some resource content with a known length.
 */
public interface ReadableContent {
    /**
     * Unbuffered input stream to read contents of resource.
     */
    InputStream open() throws ResourceException;

    long getContentLength();

            }
            throw e;
        }
    }

    private static class ProgressLoggingReadableContent implements ReadableContent {
        private final ReadableContent delegate;
        private final ResourceOperation uploadOperation;

        private ProgressLoggingReadableContent(ReadableContent delegate, ResourceOperation uploadOperation) {
            this.delegate = delegate;
            this.uploadOperation = uploadOperation;

import org.apache.http.client.methods.HttpPut;
import org.apache.http.entity.ContentType;
import org.gradle.internal.resource.ExternalResourceName;
import org.gradle.internal.resource.ReadableContent;
import org.gradle.internal.resource.transfer.ExternalResourceUploader;

import java.io.IOException;
import java.net.URI;

public class HttpResourceUploader implements ExternalResourceUploader {

import org.gradle.internal.IoActions;
import org.gradle.internal.resource.ReadableContent;

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

public class RepeatableInputStreamEntity extends AbstractHttpEntity {
    private final ReadableContent source;

    public RepeatableInputStreamEntity(ReadableContent source, ContentType contentType) {
        super();
        this.source = source;

 * limitations under the License.
 */

package org.gradle.internal.resource.local;

import org.gradle.internal.resource.ReadableContent;

import java.io.ByteArrayInputStream;
import java.io.InputStream;

public class ByteArrayReadableContent implements ReadableContent {
    private final byte[] source;

    public ByteArrayReadableContent(byte[] source) {
        this.source = source;
    }

 */

package org.gradle.internal.resource.local;

import org.gradle.internal.resource.ReadableContent;
import org.gradle.internal.resource.ResourceExceptions;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;

public class FileReadableContent implements ReadableContent {
    private final File file;

    public FileReadableContent(File file) {

import com.google.api.services.storage.model.StorageObject;
import org.gradle.api.resources.ResourceException;
import org.gradle.internal.resource.ExternalResourceName;
import org.gradle.internal.resource.ReadableContent;
import org.gradle.internal.resource.metadata.ExternalResourceMetaData;
import org.gradle.internal.resource.transfer.AbstractExternalResourceAccessor;
import org.gradle.internal.resource.transfer.ExternalResourceConnector;

        return accessor.getMetaData(name, revalidate);
    }

    private static class CountingReadableContent implements ReadableContent {
        private final ReadableContent source;
        private CountingInputStream instr;
        private long count;

        CountingReadableContent(ReadableContent source) {
            this.source = source;
        }

        @Override

import org.gradle.internal.resource.ExternalResourceName
import org.gradle.internal.resource.ReadableContent

class HttpResourceUploaderTest extends AbstractHttpClientTest {

    def 'uploader closes the request'() {
        given:
        HttpClientHelper client = Mock()
        ReadableContent resource = Mock()
        MockedHttpResponse mockedHttpResponse = mockedHttpResponse()

import org.gradle.internal.resource.ExternalResourceName;
import org.gradle.internal.resource.ReadableContent;

import java.io.IOException;

/**
 * You should use {@link ExternalResource} instead of this type.
 */
public interface ExternalResourceUploader {
    void upload(ReadableContent resource, ExternalResourceName destination) throws IOException;