module MSS::Core::AsyncHandle
Mixin that provides a generic callback facility for asynchronous tasks that can either succeed or fail.
Public Instance Methods
Registers a callback to be called when the task is complete, regardless of its status. Yields the status to the block.
handle.on_complete do |status| puts "It #{status == :success ? 'did' : 'did not'} work!" end
If this is called when the task has already completed, it will call the callback immediately.
# File lib/mss/core/async_handle.rb, line 68 def on_complete(&block) if !@_async_status.nil? block.call(@_async_status) else (@_async_callbacks ||= []) << { :failure => lambda { block.call(:failure) }, :success => lambda { block.call(:success) } } end end
Registers a callback to be called when the task fails.
handle.on_failure { puts "It didn't work!" }
If this is called when the task has already failed, it will call the callback immediately.
# File lib/mss/core/async_handle.rb, line 51 def on_failure(&block) if @_async_status == :failure block.call else (@_async_callbacks ||= []) << { :failure => block } end end
Registers a callback to be called on successful completion of the task.
handle.on_success { puts "It worked!" }
If this is called when the task has already completed successfully, it will call the callback immediately.
# File lib/mss/core/async_handle.rb, line 37 def on_success(&block) if @_async_status == :success block.call else (@_async_callbacks ||= []) << { :success => block } end end
Called to signal failure and fire off the failure and complete callbacks.
# File lib/mss/core/async_handle.rb, line 26 def signal_failure __send_signal(:failure) end
Called to signal success and fire off the success and complete callbacks.
# File lib/mss/core/async_handle.rb, line 21 def signal_success __send_signal(:success) end
Private Instance Methods
# File lib/mss/core/async_handle.rb, line 80 def __send_signal(kind) @_async_status = kind @_async_callbacks.map do |cb| cb[kind] end.compact.each {|block| block.call } if @_async_callbacks end