File tree Expand file tree Collapse file tree 2 files changed +5
-8
lines changed Expand file tree Collapse file tree 2 files changed +5
-8
lines changed Original file line number Diff line number Diff line change @@ -7,14 +7,12 @@ def self.with_defaults
7
7
end
8
8
9
9
def self . with (
10
- event_store : Rails . configuration . event_store ,
11
- event_store_locator : nil ,
12
- serializer : RubyEventStore ::Serializers ::YAML
10
+ serializer : RubyEventStore ::Serializers ::YAML ,
11
+ event_store_locator : -> { Rails . configuration . event_store }
13
12
)
14
13
Module . new do
15
14
define_method :perform do |payload |
16
- event_store = event_store_locator . call if event_store_locator
17
- super ( event_store . deserialize ( serializer : serializer , **payload . transform_keys ( &:to_sym ) ) )
15
+ super ( event_store_locator . call . deserialize ( serializer : serializer , **payload . transform_keys ( &:to_sym ) ) )
18
16
end
19
17
end
20
18
end
Original file line number Diff line number Diff line change @@ -95,15 +95,14 @@ def perform(event)
95
95
end
96
96
97
97
specify "with specified event store" do
98
- HandlerWithAnotherEventStore . prepend RailsEventStore ::AsyncHandler . with ( event_store : another_event_store )
98
+ HandlerWithAnotherEventStore . prepend RailsEventStore ::AsyncHandler . with ( event_store_locator : -> { another_event_store } )
99
99
event_store . subscribe_to_all_events ( HandlerWithAnotherEventStore )
100
100
event_store . publish ( ev = RubyEventStore ::Event . new )
101
101
expect ( $queue. pop ) . to eq ( ev )
102
102
end
103
103
104
104
specify "with specified event store locator" do
105
105
HandlerWithEventStoreLocator . prepend RailsEventStore ::AsyncHandler . with (
106
- event_store : nil ,
107
106
event_store_locator : -> { another_event_store }
108
107
)
109
108
another_event_store . subscribe_to_all_events ( HandlerWithEventStoreLocator )
@@ -113,7 +112,7 @@ def perform(event)
113
112
114
113
specify "with specified serializer" do
115
114
HandlerWithSpecifiedSerializer . prepend RailsEventStore ::AsyncHandler . with (
116
- event_store : json_event_store ,
115
+ event_store_locator : -> { json_event_store } ,
117
116
serializer : JSON
118
117
)
119
118
json_event_store . subscribe_to_all_events ( HandlerWithSpecifiedSerializer )
You can’t perform that action at this time.
0 commit comments