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