Class: Celluloid::Promise::ResolvedPromise

Inherits:
Promise
  • Object
show all
Defined in:
lib/celluloid-promise/q.rb

Instance Method Summary collapse

Constructor Details

#initialize(reactor, response, error = false) ⇒ ResolvedPromise

Returns a new instance of ResolvedPromise.

Raises:

  • (ArgumentError) 


111
112
113
114
115
116
117
118
 
# File 'lib/celluloid-promise/q.rb', line 111

def initialize(reactor, response, error = false)
	raise ArgumentError if error && response.is_a?(Promise)
	super()
	
	@error = error
	@response = response
	@reactor = reactor
end

Instance Method Details

#then(callback = nil, errback = nil, &blk) ⇒ Object 



120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
 
# File 'lib/celluloid-promise/q.rb', line 120

def then(callback = nil, errback = nil, &blk)
	result = ::Celluloid::Actor[:Q].defer(@reactor)
	
	callback ||= blk
	
	@reactor.async.perform do
		if @error
			if errback.nil?
				result.resolve(ResolvedPromise.new(@reactor, @response, true))
			else
				result.resolve(errback.call(@response))
			end
		else
			if callback.nil?
				result.resolve(@response)
			else
				result.resolve(callback.call(@response))
			end
		end
	end
	
	result.promise
end