Class: RPC::Clients::EmHttpRequest

Inherits:

Object

• Object
• RPC::Clients::EmHttpRequest

show all

Defined in:

lib/rpc/lib/rpc/clients/em-http-request.rb

Instance Method Summary (collapse)

• - (Boolean) async?
• - (Object) connect
• - (Object) disconnect
• - (EmHttpRequest) initialize(uri) constructor

  A new instance of EmHttpRequest.

• - (Object) run(&block)
• - (Object) send(data, &callback)

18
19
20
21

# File 'lib/rpc/lib/rpc/clients/em-http-request.rb', line 18

def initialize(uri)
  @client = EventMachine::HttpRequest.new(uri)
  @in_progress = 0
end

53
54
55

# File 'lib/rpc/lib/rpc/clients/em-http-request.rb', line 53

def async?
  true
end

23
24

# File 'lib/rpc/lib/rpc/clients/em-http-request.rb', line 23

def connect
end

26
27

# File 'lib/rpc/lib/rpc/clients/em-http-request.rb', line 26

def disconnect
end

29
30
31
32
33
34
35
36
37
38
39

# File 'lib/rpc/lib/rpc/clients/em-http-request.rb', line 29

def run(&block)
  EM.run do
    block.call

    # Note: There's no way how to stop the
    # reactor when there are no remaining events.
    EM.add_periodic_timer(0.1) do
      EM.stop if @in_progress == 0
    end
  end
end

41
42
43
44
45
46
47
48
49
50
51

# File 'lib/rpc/lib/rpc/clients/em-http-request.rb', line 41

def send(data, &callback)
  request = @client.post(head: HEADERS, body: data)
  @in_progress += 1
  request.callback do |response|
    if callback
      callback.call(response.response)
    end

    @in_progress -= 1
  end
end