Class: Unity::DynamoDBStreams::EventProcessor::TableHandler

Inherits:

Object

show all

Instance Method Summary collapse

Returns a new instance of TableHandler.



49
50
51

# File 'lib/unity/dynamodbstreams/event_processor.rb', line 49

def initialize
  @handlers = { insert: [], remove: [], update: [] }
end



69
70
71

# File 'lib/unity/dynamodbstreams/event_processor.rb', line 69

def each(type, &block)
  @handlers[type].each(&block)
end



53
54
55

# File 'lib/unity/dynamodbstreams/event_processor.rb', line 53

def on(type, handler = nil, &block)
  @handlers[type] << handler || block
end



57
58
59

# File 'lib/unity/dynamodbstreams/event_processor.rb', line 57

def on_insert(handler = nil, &block)
  on(:insert, handler || block)
end



61
62
63

# File 'lib/unity/dynamodbstreams/event_processor.rb', line 61

def on_remove(handler = nil, &block)
  on(:remove, handler || block)
end



65
66
67

# File 'lib/unity/dynamodbstreams/event_processor.rb', line 65

def on_update(handler = nil, &block)
  on(:update, handler || block)
end