Module: Libuv::Q
- Included in:
- Deferred
- Defined in:
- lib/libuv/q.rb
Defined Under Namespace
Classes: Deferred, DeferredPromise, Promise, ResolvedPromise
Class Method Summary collapse
-
.all(reactor, *promises) ⇒ Promise
Combines multiple promises into a single promise that is resolved when all of the input promises are resolved.
-
.any(reactor, *promises) ⇒ Promise
Combines multiple promises into a single promise that is resolved when any of the input promises are resolved.
-
.defer(reactor) ⇒ Deferred
Creates a Deferred object which represents a task which will finish in the future.
-
.finally(reactor, *promises) ⇒ Promise
Combines multiple promises into a single promise that is resolved when all of the input promises are resolved or rejected.
-
.reject(reactor, reason = nil) ⇒ Promise
Creates a promise that is resolved as rejected with the specified reason.
Class Method Details
.all(reactor, *promises) ⇒ Promise
Combines multiple promises into a single promise that is resolved when all of the input promises are resolved.
368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 |
# File 'lib/libuv/q.rb', line 368 def all(reactor, *promises) deferred = Q.defer(reactor) promises = promises.flatten counter = promises.length results = [] if counter > 0 promises.each_index do |index| ref(reactor, promises[index]).then(proc {|result| if results[index].nil? results[index] = result counter -= 1 deferred.resolve(results) if counter <= 0 end result }, proc {|reason| if results[index].nil? deferred.reject(reason) end Q.reject(@reactor, reason) # Don't modify result }) end else deferred.resolve(results) end return deferred.promise end |
.any(reactor, *promises) ⇒ Promise
Combines multiple promises into a single promise that is resolved when any of the input promises are resolved.
404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 |
# File 'lib/libuv/q.rb', line 404 def any(reactor, *promises) deferred = Q.defer(reactor) promises = promises.flatten if promises.length > 0 promises.each_index do |index| ref(reactor, promises[index]).then(proc { |result| deferred.resolve(result) }, proc { |reason| deferred.reject(reason) Q.reject(@reactor, reason) # Don't modify result }) end else deferred.resolve(true) end deferred.promise end |
.defer(reactor) ⇒ Deferred
Creates a Deferred object which represents a task which will finish in the future.
317 318 319 |
# File 'lib/libuv/q.rb', line 317 def defer(reactor) return Deferred.new(reactor) end |
.finally(reactor, *promises) ⇒ Promise
Combines multiple promises into a single promise that is resolved when all of the input promises are resolved or rejected.
430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 |
# File 'lib/libuv/q.rb', line 430 def self.finally(reactor, *promises) deferred = Q.defer(reactor) promises = promises.flatten counter = promises.length results = [] if counter > 0 promises.each_index do |index| ref(reactor, promises[index]).then(proc {|result| if results[index].nil? results[index] = [result, true] counter -= 1 deferred.resolve(results) if counter <= 0 end result }, proc {|reason| if results[index].nil? results[index] = [reason, false] counter -= 1 deferred.resolve(results) if counter <= 0 end Q.reject(@reactor, reason) # Don't modify result }) end else deferred.resolve(results) end return deferred.promise end |
.reject(reactor, reason = nil) ⇒ Promise
Creates a promise that is resolved as rejected with the specified reason. This api should be used to forward rejection in a chain of promises. If you are dealing with the last promise in a promise chain, you don’t need to worry about it.
When comparing deferreds/promises to the familiar behaviour of try/catch/throw, think of reject as the raise keyword in Ruby. This also means that if you “catch” an error via a promise error callback and you want to forward the error to the promise derived from the current promise, you have to “rethrow” the error by returning a rejection constructed via reject.
355 356 357 |
# File 'lib/libuv/q.rb', line 355 def reject(reactor, reason = nil) return ResolvedPromise.new(reactor, reason, true) # A resolved failed promise end |