Module: TestBench::Telemetry::Sink::Handler
Defined Under Namespace
Modules: HandleMacro, HandlerMethod, Receive
Classes: EventRegistry
Class Method Summary
collapse
Instance Method Summary
collapse
Class Method Details
.included(cls) ⇒ Object
5
6
7
8
9
10
11
12
13
|
# File 'lib/test_bench/telemetry/sink/handler.rb', line 5
def self.included(cls)
cls.class_exec do
include Sink
include Receive
extend HandlerMethod
extend HandleMacro
end
end
|
Instance Method Details
#handle(event_or_event_data) ⇒ Object
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
# File 'lib/test_bench/telemetry/sink/handler.rb', line 21
def handle(event_or_event_data)
handles = handle?(event_or_event_data)
if handles
if event_or_event_data.is_a?(Event)
event = event_or_event_data
else
event_data = event_or_event_data
event_type = event_data.type
event_class = self.class.event_registry.get(event_type)
event = Event::Import.(event_data, event_class)
end
handler_method = handler_method(event)
if method(handler_method).parameters.any?
__send__(handler_method, event)
else
__send__(handler_method)
end
event
elsif respond_to?(:handle_event_data)
if event_or_event_data.is_a?(Event)
event_data = Event::Export.(event_or_event_data)
else
event_data = event_or_event_data
end
handle_event_data(event_data)
event_data
else
nil
end
end
|
#handle? ⇒ Boolean
59
60
61
62
63
|
# File 'lib/test_bench/telemetry/sink/handler.rb', line 59
def handle?(...)
handler_method = handler_method(...)
not handler_method.nil?
end
|
#handler_method(event_or_event_data) ⇒ Object
65
66
67
68
69
70
71
72
73
|
# File 'lib/test_bench/telemetry/sink/handler.rb', line 65
def handler_method(event_or_event_data)
handler_method = self.class.handler_method(event_or_event_data)
if respond_to?(handler_method)
handler_method
else
nil
end
end
|