Class: Promise::When

370
371
372
373
374
375
376
377
378

# File 'opal/stdlib/promise.rb', line 370
def initialize(promises = [])
 super()
 @wait = []
 promises.each {|promise|
 wait promise
 }
end

426
427
428
429
430

# File 'opal/stdlib/promise.rb', line 426
def >>(*)
 super.tap {
 try
 }
end

388
389
390
391
392
393
394

# File 'opal/stdlib/promise.rb', line 388
def collect(&block)
 raise ArgumentError, 'no block given' unless block
 self.then {|values|
 When .new (values.map(&block))
 }
end

380
381
382
383
384
385
386

# File 'opal/stdlib/promise.rb', line 380
def each(&block)
 raise ArgumentError, 'no block given' unless block
 self.then {|values|
 values.each(&block)
 }
end

396
397
398
399
400

# File 'opal/stdlib/promise.rb', line 396
def inject(*args, &block)
 self.then {|values|
 values.reduce(*args, &block)
 }
end

432
433
434
435
436
437
438
439
440

# File 'opal/stdlib/promise.rb', line 432
def try
 if @wait.all?(&:realized?)
 if promise = @wait.find(&:rejected?)
 reject(promise.error)
 else
 resolve(@wait.map(&:value))
 end
 end
end

406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422

# File 'opal/stdlib/promise.rb', line 406
def wait(promise)
 unless Promise  === promise
 promise = Promise .value (promise)
 end
 if promise.act?
 promise = promise.then
 end
 @wait << promise
 promise.always {
 try if @next.any?
 }
 self
end