Class: Celluloid::Promise::Deferred

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

Overview

The purpose of the deferred object is to expose the associated Promise instance as well as APIs that can be used for signalling the successful or unsuccessful completion of a task.

Instance Method Summary collapse

Constructor Details

#initialize(reactor) ⇒ Deferred

Returns a new instance of Deferred.



153
154
155
156
157
158
159
 
# File 'lib/celluloid-promise/q.rb', line 153

def initialize(reactor)
	super()
	
	@reactor = reactor
	@pending = []
	@value = nil
end

Instance Method Details

#promise ⇒ Object

Creates a promise object associated with this deferred



194
195
196
 
# File 'lib/celluloid-promise/q.rb', line 194

def promise
	DeferredPromise.new( self, @reactor )
end

#reject(reason = nil) ⇒ Object

rejects the derived promise with the reason. This is equivalent to resolving it with a rejection constructed via Q.reject.

Parameters:

  • reason (Object) (defaults to: nil) —

    constant, message, exception or an object representing the rejection reason.



187
188
189
 
# File 'lib/celluloid-promise/q.rb', line 187

def reject(reason = nil)
	resolve(ResolvedPromise.new(@reactor, reason, true))
end

#resolve(val = nil) ⇒ Object

resolves the derived promise with the value. If the value is a rejection constructed via Q.reject, the promise will be rejected instead.

Parameters:

  • val (Object) (defaults to: nil) —

    constant, message or an object representing the result.



166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
 
# File 'lib/celluloid-promise/q.rb', line 166

def resolve(val = nil)
	@reactor.async.perform do
		if not @pending.nil?
			callbacks = @pending
			@pending = nil
			@value = ref(val)
			
			if callbacks.length > 0
				callbacks.each do |callback|
					@value.then(callback[0], callback[1])
				end
			end
		end
	end
end