Class: DeepConnect::Event::AsyncronusRequest

Inherits:

Request

• Object
• Event
• Request
• DeepConnect::Event::AsyncronusRequest

Defined in:

lib/deep-connect/event.rb

Instance Attribute Summary

Attributes inherited from Request

#args, #method

Attributes inherited from Event

#receiver, #seq, #session

Class Method Summary

• .receipt(session, seq, receiver, method, args) ⇒ Object
• .request(session, receiver, method, args, callback) ⇒ Object

Instance Method Summary

• #initialize(session, receiver, method, args, callback = nil) ⇒ AsyncronusRequest constructor

  A new instance of AsyncronusRequest.

• #reply_class ⇒ Object
• #result=(ev) ⇒ Object

Methods inherited from Request

#create_exception, #init_req, #inspect, materialize_sub, #reply, #request?, #result, #result_event, #serialize, #set_seq

Methods inherited from Event

#inspect

Constructor Details

#initialize(session, receiver, method, args, callback = nil) ⇒ AsyncronusRequest

Returns a new instance of AsyncronusRequest.

# File 'lib/deep-connect/event.rb', line 295

def initialize(session, receiver, method, args, callback = nil)
	super(session, receiver, method, args)
	@callback = callback
end

Class Method Details

.receipt(session, seq, receiver, method, args) ⇒ Object

# File 'lib/deep-connect/event.rb', line 288

def AsyncronusRequest.receipt(session, seq, receiver, method, args)
	rec = new(session, receiver, method, args)
	rec.set_seq(seq)
	rec
end

.request(session, receiver, method, args, callback) ⇒ Object

# File 'lib/deep-connect/event.rb', line 282

def AsyncronusRequest.request(session, receiver, method, args, callback)
	req = new(session, receiver, method, args, callback)
	req.init_req
	req
end

Instance Method Details

#reply_class ⇒ Object

# File 'lib/deep-connect/event.rb', line 300

def reply_class
	AsyncronusReply
end

#result=(ev) ⇒ Object

# File 'lib/deep-connect/event.rb', line 304

def result=(ev)
	@result = ev
	if @callback
	  Thread.start do
	    if ev.exp
 exp = create_exception
 @callback.call(nil, exp)
	    else
 @callback.call(ev.result, nil)
	    end
	  end
	end
end