module Ethon::Easy::Callbacks

def self.included(base)

:nodoc:
def self.included(base)
  base.send(:attr_accessor, *[:response_body, :response_headers, :debug_info])
end

def body_write_callback

Returns:
  • (Proc) - The callback.

Other tags:
    Example: Return the callback. -
def body_write_callback
  @body_write_callback ||= proc {|stream, size, num, object|
    @response_body << stream.read_string(size * num)
    size * num
  }
end

def debug_callback

Returns:
  • (Proc) - The callback.

Other tags:
    Example: Return the callback. -
def debug_callback
  @debug_callback ||= proc {|handle, type, data, size, udata|
    message = data.read_string(size)
    @debug_info.add type, message
    print message unless [:data_in, :data_out].include?(type)
    0
  }
end

def header_write_callback

Returns:
  • (Proc) - The callback.

Other tags:
    Example: Return the callback. -
def header_write_callback
  @header_write_callback ||= proc {|stream, size, num, object|
    @response_headers << stream.read_string(size * num)
    size * num
  }
end

def read_callback

Returns:
  • (Proc) - The callback.

Other tags:
    Example: Return the callback. -
def read_callback
  @read_callback
end

def set_callbacks

Other tags:
    Example: Set callbacks. -
def set_callbacks
  Curl.set_option(:writefunction, body_write_callback, handle)
  Curl.set_option(:headerfunction, header_write_callback, handle)
  Curl.set_option(:debugfunction, debug_callback, handle)
  @response_body = ""
  @response_headers = ""
  @debug_info = Ethon::Easy::DebugInfo.new
end

def set_read_callback(body)

Parameters:
  • body (String) -- The body.

Other tags:
    Example: Set the callback. -
def set_read_callback(body)
  @request_body_read = 0
  readfunction do |stream, size, num, object|
    size = size * num
    body_size = if body.respond_to?(:bytesize)
      body.bytesize
    elsif body.respond_to?(:size)
      body.size
    elsif body.is_a?(File)
      File.size(body.path)
    end
    left = body_size - @request_body_read
    size = left if size > left
    if size > 0
      chunk = if body.respond_to?(:byteslice)
        body.byteslice(@request_body_read, size)
      elsif body.respond_to?(:read)
        body.read(size)
      else
        body[@request_body_read, size]
      end
      stream.write_string(
        chunk, size
      )
      @request_body_read += size
    end
    size
  end
end