class Cassandra::Promise::Signal::Listeners::Fallback

Public Class Methods

new(promise, &block) click to toggle source
    # File lib/cassandra/future.rb
484 def initialize(promise, &block)
485   @promise = promise
486   @block   = block
487 end

Public Instance Methods

failure(error) click to toggle source
    # File lib/cassandra/future.rb
495 def failure(error)
496   result = @block.call(error)
497 
498   if result.is_a?(Future)
499     @promise.observe(result)
500   else
501     @promise.fulfill(result)
502   end
503 rescue => e
504   @promise.break(e)
505 ensure
506   @promise = @block = nil
507 end
success(value) click to toggle source
    # File lib/cassandra/future.rb
489 def success(value)
490   @promise.fulfill(value)
491 ensure
492   @promise = @block = nil
493 end