}

        @Override
        public void disconnect() {
            // Do Nothing
        }

        @Override
        public boolean usingProxy() {
            return false;
        }

        @Override
        public void connect() throws IOException {
            // Do Nothing
        }

        @Override
        public int getResponseCode() throws IOException {
            return 200;

import java.util.logging.Logger;

public class ContentCache implements Closeable {

    protected static final Logger logger = Logger.getLogger(ContentCache.class.getName());

    private final byte[] data;

    private final File file;

    public ContentCache(final byte[] data) {
        this.data = data;
        this.file = null;
    }

    public ContentCache(final File file) {
        this.data = null;

import static org.junit.Assert.assertTrue;

import java.io.File;
import java.io.IOException;

import org.codelibs.curl.Curl;
import org.junit.Test;

public class ContentOutputStreamTest {

    @Test
    public void inMemory() throws IOException {
        ContentOutputStream cos = new ContentOutputStream(10, Curl.tmpDir);
        cos.write(new byte[] { 0, 1, 2, 3, 4 });
        assertFalse(cos.done);

import static org.junit.Assert.fail;

import java.util.logging.Level;
import java.util.logging.Logger;

import org.junit.Test;

public class CurlTest {
    private static final Logger logger = Logger.getLogger(CurlTest.class.getName());

    @Test
    public void test_Get() {
        Curl.get("https://www.codelibs.org/").execute(response -> {
            final String content = response.getContentAsString();

        return contentCache.getInputStream();
    }

    public void setContentCache(final ContentCache contentCache) {
        this.contentCache = contentCache;
    }

    public int getHttpStatusCode() {
        return httpStatusCode;
    }

    public void setHttpStatusCode(final int httpStatusCode) {
        this.httpStatusCode = httpStatusCode;
    }

    public String getEncoding() {
        return encoding;
    }

 * governing permissions and limitations under the License.
 */
package org.codelibs.curl;

public class CurlException extends RuntimeException {

    private static final long serialVersionUID = 1L;

    public CurlException(final String message, final Throwable cause) {
        super(message, cause);
    }

    public CurlException(final String message) {
        super(message);
    }

import org.apache.commons.io.output.DeferredFileOutputStream;

public class ContentOutputStream extends DeferredFileOutputStream {

    protected static final Logger logger = Logger.getLogger(ContentOutputStream.class.getName());

    protected static final String PREFIX = "curl4j-";

    protected static final String SUFFIX = ".tmp";

    protected boolean done = false;

    public ContentOutputStream(final int threshold, final File tmpDir) {

    public CurlRequest(final Method method, final String url) {
        this.method = method;
        this.url = url;
    }

    public Proxy proxy() {
        return proxy;
    }

    public String encoding() {
        return encoding;
    }

    public int threshold() {
        return threshold;
    }

    public Method method() {
        return method;
    }

 */
package org.codelibs.curl;

import java.io.File;

public class Curl {

    public static final File tmpDir = new File(System.getProperty("java.io.tmpdir"));

    protected Curl() {
        // nothing
    }

    public static CurlRequest get(final String url) {
        return new CurlRequest(Method.GET, url);
    }

    public static CurlRequest post(final String url) {