Class: Smith::PersistenceAdapters::RedisExactWrite

Inherits:
Object
  • Object
show all
Extended by:
Dry::Initializer
Defined in:
lib/smith/persistence_adapters/redis_exact_write.rb

Instance Method Summary collapse

Instance Method Details

#call ⇒ Object

Raises:



17
18
19
20
21
22
23
24
25
 
# File 'lib/smith/persistence_adapters/redis_exact_write.rb', line 17

def call
  result = client.watch(storage_key) do
    validate_current!
    enqueue_write
  end
  return payload unless result.nil?

  raise PersistencePayloadConflict.new(key:)
end