class RubyEventStore::ROM::Memory::SpecHelper

Attributes

close_pool_connection[R]
connection_pool_size[R]
env[R]

Public Class Methods

new() click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 45
def initialize
  @connection_pool_size = 5
  @env = ROM.setup(:memory)
end

Public Instance Methods

close_gateway_connection() click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 64
def close_gateway_connection
  gateway.disconnect
end
drop_gateway_schema() click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 60
def drop_gateway_schema
  gateway.connection.data.values.each { |v| v.data.clear }
end
gateway() click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 56
def gateway
  env.rom_container.gateways.fetch(:default)
end
gateway_type?(name) click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 68
def gateway_type?(name)
  name == :memory
end
has_connection_pooling?() click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 72
def has_connection_pooling?
  true
end
run_lifecycle() { || ... } click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 50
def run_lifecycle
  yield
ensure
  drop_gateway_schema
end
supports_upsert?() click to toggle source
# File lib/ruby_event_store/rom/memory.rb, line 76
def supports_upsert?
  true
end