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