Class: Promise::When

355
356
357
358
359
360
361
362
363

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

411
412
413
414
415

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

373
374
375
376
377
378
379

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

365
366
367
368
369
370
371

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

381
382
383
384
385

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

417
418
419
420
421
422
423
424
425

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

391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407

# File 'opal/stdlib/promise.rb', line 391
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
 }
 self
end