Module: FastCurl

Defined in:

lib/fast_curl.rb,
lib/fast_curl/version.rb,
ext/fast_curl/fast_curl.c

Defined Under Namespace

Classes: Error, TimeoutError

Constant Summary

DEFAULT_OPTIONS =

{
  connections: 20,
  timeout: 30
}.freeze

METHODS =

%i[get post put delete patch].freeze

BODY_METHODS =

%i[post put patch].freeze

VERSION =

"0.3.1"

Class Method Summary

• .execute(*args) ⇒ Object
• .first_execute(*args) ⇒ Object
• .stream_execute(*args) ⇒ Object

Class Method Details

.execute(*args) ⇒ Object

# File 'ext/fast_curl/fast_curl.c', line 1333

static VALUE rb_fast_curl_execute(int argc, VALUE *argv, VALUE self) {
    VALUE requests, options;
    rb_scan_args(argc, argv, "1:", &requests, &options);
    return internal_execute(requests, options, -1, 0);
}

.first_execute(*args) ⇒ Object

# File 'ext/fast_curl/fast_curl.c', line 1339

static VALUE rb_fast_curl_first_execute(int argc, VALUE *argv, VALUE self) {
    VALUE requests, options;
    rb_scan_args(argc, argv, "1:", &requests, &options);

    int count = 1;
    if (!NIL_P(options)) {
        Check_Type(options, T_HASH);
        VALUE c = hash_aref_key(options, KEY_COUNT_OPT);
        if (!NIL_P(c))
            count = NUM2INT(c);
    }

    if (count <= 0)
        rb_raise(rb_eArgError, "count must be positive");

    return internal_execute(requests, options, count, 0);
}

.stream_execute(*args) ⇒ Object

# File 'ext/fast_curl/fast_curl.c', line 1357

static VALUE rb_fast_curl_stream_execute(int argc, VALUE *argv, VALUE self) {
    VALUE requests, options;
    rb_scan_args(argc, argv, "1:", &requests, &options);

    if (!rb_block_given_p())
        rb_raise(rb_eArgError, "stream_execute requires a block");

    return internal_execute(requests, options, -1, 1);
}