Method: CloudI::API#recv_async

Defined in:
lib/cloudi.rb

#recv_async(timeout = nil, trans_id = nil, consume = true) ⇒ Object 



231
232
233
234
235
236
237
238
239
240
241
242
 
# File 'lib/cloudi.rb', line 231

def recv_async(timeout=nil, trans_id=nil, consume=true)
    if timeout.nil?
        timeout = @timeout_sync
    end
    if trans_id.nil?
        trans_id = 0.chr * 16
    end
    send(Erlang.term_to_binary([:recv_async, timeout,
                                OtpErlangBinary.new(trans_id),
                                consume]))
    return poll_request(nil, false)
end