class Cassandra::Promise::Signal::Listeners::Then

Public Class Methods

new(promise, &block) click to toggle source
    # File lib/cassandra/future.rb
457 def initialize(promise, &block)
458   @promise = promise
459   @block   = block
460 end

Public Instance Methods

failure(error) click to toggle source
    # File lib/cassandra/future.rb
476 def failure(error)
477   @promise.break(error)
478 ensure
479   @promise = @block = nil
480 end
success(value) click to toggle source
    # File lib/cassandra/future.rb
462 def success(value)
463   result = @block.call(value)
464 
465   if result.is_a?(Future)
466     @promise.observe(result)
467   else
468     @promise.fulfill(result)
469   end
470 rescue => e
471   @promise.break(e)
472 ensure
473   @promise = @block = nil
474 end