Class: Messaging::Write::Substitute::Write
- Inherits:
-
Object
- Object
- Messaging::Write::Substitute::Write
show all
- Includes:
- Messaging::Write
- Defined in:
- lib/messaging/write/substitute.rb
Instance Attribute Summary collapse
Class Method Summary
collapse
Instance Method Summary
collapse
included, #initial, #message_data_batch, register_telemetry_sink, #reply
Instance Attribute Details
#raise_expected_version_error ⇒ Object
18
19
20
|
# File 'lib/messaging/write/substitute.rb', line 18
def raise_expected_version_error
@raise_expected_version_error ||= false
end
|
#sink ⇒ Object
Returns the value of attribute sink.
16
17
18
|
# File 'lib/messaging/write/substitute.rb', line 16
def sink
@sink
end
|
Class Method Details
.build(session: nil) ⇒ Object
23
24
25
26
27
|
# File 'lib/messaging/write/substitute.rb', line 23
def self.build(session: nil)
new.tap do |instance|
::Telemetry.configure instance
end
end
|
Instance Method Details
#call(*args, **keyword_args) ⇒ Object
Also known as:
write
29
30
31
32
|
# File 'lib/messaging/write/substitute.rb', line 29
def call(*args, **keyword_args)
raise MessageStore::ExpectedVersion::Error if raise_expected_version_error
super(*args, **keyword_args)
end
|
#message_replies(&blk) ⇒ Object
148
149
150
151
152
153
154
155
156
|
# File 'lib/messaging/write/substitute.rb', line 148
def message_replies(&blk)
if blk.nil?
return sink.replied_records.map { |record| record.data.message }
end
sink.replied_records.select do |record|
blk.call(record.data.message, record.data.stream_name)
end.map { |record| record.data.message }
end
|
#message_writes(&blk) ⇒ Object
127
128
129
130
131
132
133
134
135
|
# File 'lib/messaging/write/substitute.rb', line 127
def message_writes(&blk)
if blk.nil?
return sink.written_records.map { |record| record.data.message }
end
sink.written_records.select do |record|
blk.call(record.data.message, record.data.stream_name, record.data.expected_version, record.data.reply_stream_name)
end.map { |record| record.data.message }
end
|
#one_message_reply(&blk) ⇒ Object
Also known as:
one_reply
158
159
160
161
162
163
164
165
166
|
# File 'lib/messaging/write/substitute.rb', line 158
def one_message_reply(&blk)
messages = message_replies(&blk)
if messages.length > 1
raise Substitute::Error, "More than one matching message reply was written"
end
messages.first
end
|
#one_message_write(&blk) ⇒ Object
Also known as:
one_message
137
138
139
140
141
142
143
144
145
|
# File 'lib/messaging/write/substitute.rb', line 137
def one_message_write(&blk)
messages = message_writes(&blk)
if messages.length > 1
raise Substitute::Error, "More than one matching message was written"
end
messages.first
end
|
#raise_expected_version_error! ⇒ Object
Should never have had an exclamation mark - Scott, Tue Jan 17 2023
36
37
38
39
|
# File 'lib/messaging/write/substitute.rb', line 36
def raise_expected_version_error!
self.raise_expected_version_error = true
nil
end
|
#replied?(message = nil, &blk) ⇒ Boolean
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
# File 'lib/messaging/write/substitute.rb', line 94
def replied?(message=nil, &blk)
if message.nil?
if blk.nil?
return sink.recorded_replied?
end
return sink.recorded_replied? do |record|
blk.call(record.data.message, record.data.stream_name)
end
end
written = sink.recorded_replied? do |record|
record.data.message == message
end
if !written
return false
end
if blk.nil?
return true
end
sink.recorded_replied? do |record|
blk.call(record.data.stream_name)
end
end
|
#replies(&blk) ⇒ Object
84
85
86
87
88
89
90
91
92
|
# File 'lib/messaging/write/substitute.rb', line 84
def replies(&blk)
if blk.nil?
return sink.replied_records
end
sink.replied_records.select do |record|
blk.call(record.data.message, record.data.stream_name)
end
end
|
#writes(&blk) ⇒ Object
41
42
43
44
45
46
47
48
49
|
# File 'lib/messaging/write/substitute.rb', line 41
def writes(&blk)
if blk.nil?
return sink.written_records
end
sink.written_records.select do |record|
blk.call(record.data.message, record.data.stream_name, record.data.expected_version, record.data.reply_stream_name)
end
end
|
#written?(message = nil, &blk) ⇒ Boolean
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
# File 'lib/messaging/write/substitute.rb', line 51
def written?(message=nil, &blk)
if message.nil?
if blk.nil?
return sink.recorded_written?
end
return sink.recorded_written? do |record|
blk.call(record.data.message, record.data.stream_name, record.data.expected_version, record.data.reply_stream_name)
end
end
written = sink.recorded_written? do |record|
record.data.message == message
end
if !written
return false
end
if blk.nil?
return true
end
sink.recorded_written? do |record|
blk.call(record.data.stream_name, record.data.expected_version, record.data.reply_stream_name)
end
end
|