Contents

#include <curl/curl.h>
#include <ruby.h>

VALUE mStreamly, cRequest, eStreamlyError, eUnsupportedProtocol, eURLFormatError, eHostResolutionError;
VALUE eConnectionFailed, ePartialFileError, eTimeoutError, eTooManyRedirects;
VALUE sym_method, sym_url, sym_payload, sym_headers, sym_head, sym_get, sym_post, sym_put, sym_delete;
VALUE sym_response_header_handler, sym_response_body_handler, sym_username, sym_password;

#define GetInstance(obj, sval) (sval = (struct curl_instance*)DATA_PTR(obj));

#ifdef HAVE_RBTRAP
    #include <rubysig.h>
#else
    void rb_enable_interrupt(void);
    void rb_disable_interrupt(void);

    #define TRAP_BEG rb_enable_interrupt();
    #define TRAP_END do { rb_disable_interrupt(); rb_thread_check_ints(); } while(0);
#endif

struct curl_instance {
    CURL* handle;
    char error_buffer[CURL_ERROR_SIZE];
    struct curl_slist* request_headers;
    VALUE request_payload_handler;
    VALUE response_header_handler;
    VALUE response_body_handler;
    VALUE request_method;
    VALUE options;
};

// libcurl callbacks
static size_t header_handler(char * stream, size_t size, size_t nmemb, VALUE handler);
static size_t data_handler(char * stream, size_t size, size_t nmemb, VALUE handler);
// static size_t put_data_handler(char * stream, size_t size, size_t nmemb, VALUE upload_stream);
// 
static VALUE select_error(CURLcode code);
static VALUE each_http_header(VALUE header, VALUE header_array);
void streamly_instance_mark(struct curl_instance * instance);
void streamly_instance_free(struct curl_instance * instance);

VALUE rb_streamly_new(int argc, VALUE * argv, VALUE klass);
VALUE rb_streamly_new(int argc, VALUE * argv, VALUE self);

Version data entries

4 entries across 4 versions & 2 rubygems

Version	Path
brianmario-streamly-0.1.1	ext/streamly.h
brianmario-streamly-0.1.2	ext/streamly.h
brianmario-streamly-0.1.3	ext/streamly.h
streamly-0.1.3	ext/streamly.h