Class: MessagePack::RPC::AsyncResult

Inherits:
Object
  • Object
show all
Defined in:
lib/msgpack/rpc/server.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ AsyncResult

Returns a new instance of AsyncResult.



128
129
130
131
 
# File 'lib/msgpack/rpc/server.rb', line 128

def initialize
	@responder = nil
	@sent = false
end

Instance Method Details

#error(err) ⇒ Object 



145
146
147
148
 
# File 'lib/msgpack/rpc/server.rb', line 145

def error(err)
	result(nil, err)
	nil
end

#result(retval, err = nil) ⇒ Object 



133
134
135
136
137
138
139
140
141
142
143
 
# File 'lib/msgpack/rpc/server.rb', line 133

def result(retval, err = nil)
	unless @sent
		if @responder
			@responder.result(retval, err)
		else
			@result = [retval, err]
		end
		@sent = true
	end
	nil
end

#set_responder(res) ⇒ Object

:nodoc:



150
151
152
153
154
155
156
 
# File 'lib/msgpack/rpc/server.rb', line 150

def set_responder(res)  #:nodoc:
	@responder = res
	if @sent && @result
		@responder.result(*@result)
		@result = nil
	end
end