Module: TestBench::Telemetry::Sink::Projection

Included in:
Controls::Projection::Example, Controls::Projection::NoApplyMethod::Example, Controls::Projection::NoArgument::Example
Defined in:
lib/test_bench/telemetry/sink/projection.rb

Defined Under Namespace

Modules: ApplyMacro, ApplyMethod, Receive, ReceiverNameMacro

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#receiver ⇒ Object

Returns the value of attribute receiver.



17
18
19
 
# File 'lib/test_bench/telemetry/sink/projection.rb', line 17

def receiver
  @receiver
end

Class Method Details

.included(cls) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
 
# File 'lib/test_bench/telemetry/sink/projection.rb', line 5

def self.included(cls)
  cls.class_exec do
    include Sink
    include Receive

    extend ReceiverNameMacro

    extend ApplyMethod
    extend ApplyMacro
  end
end

Instance Method Details

#apply(event_or_event_data) ⇒ Object Also known as: call 



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
58
59
60
61
62
63
64
65
 
# File 'lib/test_bench/telemetry/sink/projection.rb', line 29

def apply(event_or_event_data)
  applies = apply?(event_or_event_data)

  if applies
    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

    apply_method = apply_method(event)

    if method(apply_method).parameters.any?
      __send__(apply_method, event)
    else
      __send__(apply_method)
    end

    event
  elsif respond_to?(:apply_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

    apply_event_data(event_data)

    event_data
  else
    nil
  end
end

#apply? ⇒ Boolean

Returns:

  • (Boolean) 


68
69
70
71
72
 
# File 'lib/test_bench/telemetry/sink/projection.rb', line 68

def apply?(...)
  apply_method = apply_method(...)

  not apply_method.nil?
end

#apply_method(event_or_event_data) ⇒ Object 



74
75
76
77
78
79
80
81
82
 
# File 'lib/test_bench/telemetry/sink/projection.rb', line 74

def apply_method(event_or_event_data)
  apply_method = self.class.apply_method(event_or_event_data)

  if respond_to?(apply_method)
    apply_method
  else
    nil
  end
end

#initialize(receiver) ⇒ Object 



19
20
21
 
# File 'lib/test_bench/telemetry/sink/projection.rb', line 19

def initialize(receiver)
  @receiver = receiver
end