Class: MTLibuv::Q::Deferred

Inherits:
Object show all
Includes:
MTLibuv::Q
Defined in:
lib/mt-libuv/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 Attribute Summary collapse

Instance Method Summary collapse

Methods included from MTLibuv::Q

all, any, defer, finally, reject

Constructor Details

#initialize(reactor) ⇒ Deferred

Returns a new instance of Deferred.



223
224
225
226
227
228
229
 
# File 'lib/mt-libuv/q.rb', line 223

def initialize(reactor)
    super()

    @pending = []
    @reference = nil
    @reactor = reactor
end

Instance Attribute Details

#pending ⇒ Object (readonly)

Returns the value of attribute pending.



231
232
233
 
# File 'lib/mt-libuv/q.rb', line 231

def pending
  @pending
end

#reference ⇒ Object (readonly)

Returns the value of attribute reference.



231
232
233
 
# File 'lib/mt-libuv/q.rb', line 231

def reference
  @reference
end

Instance Method Details

#inspect ⇒ Object

Overwrite to prevent inspecting errors hanging the VM



299
300
301
302
303
304
305
 
# File 'lib/mt-libuv/q.rb', line 299

def inspect
    if @pending.nil?
        "#<#{self.class}:0x#{self.__id__.to_s(16)} @reactor=#{@reactor.inspect} @reference=#{@reference.inspect}>"
    else
          "#<#{self.class}:0x#{self.__id__.to_s(16)} @reactor=#{@reactor.inspect} @pending.count=#{@pending.length}>"
    end
end

#notify(*args) ⇒ Object

Provides an asynchronous callback mechanism

Parameters:

  • data (*Object) —

    you would like to send down the promise chain.



276
277
278
279
280
281
282
283
284
285
286
287
288
 
# File 'lib/mt-libuv/q.rb', line 276

def notify(*args)
    @reactor.schedule do     # just in case we are on a different event reactor

        if @pending && @pending.length > 0
            callbacks = @pending
            @reactor.next_tick do
                callbacks.each do |callback|
                    callback[2].call(*args)
                end
            end
        end
    end
    self
end

#promise ⇒ Object

Creates a promise object associated with this deferred



267
268
269
270
 
# File 'lib/mt-libuv/q.rb', line 267

def promise
    @promise ||= DeferredPromise.new(@reactor, self)
    @promise # Should only ever be one per deferred

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.



260
261
262
 
# File 'lib/mt-libuv/q.rb', line 260

def reject(reason = nil)
    resolve(Q.reject(@reactor, reason))
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.



238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
 
# File 'lib/mt-libuv/q.rb', line 238

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

#resolved? ⇒ Boolean

Returns:

  • (Boolean) 


290
291
292
 
# File 'lib/mt-libuv/q.rb', line 290

def resolved?
    @pending.nil?
end

#value ⇒ Object 



294
295
296
 
# File 'lib/mt-libuv/q.rb', line 294

def value
    ::MTLibuv.co(self.promise)
end