Skip to content

Commit 7a9a492

Browse files
committed
Rename ImmediateAsyncDispatcher to ImmediateDispatcher
The dispatcher doesn't indicate that the message will be handled asynchronously. It indicates that the event will be dispatched immediately. No matter if it's handled sync or async
1 parent 30819b0 commit 7a9a492

File tree

11 files changed

+13
-13
lines changed

11 files changed

+13
-13
lines changed

contrib/ruby_event_store-outbox/README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ In your event store configuration, as a dispatcher use `RubyEventStore::Immediat
2525
```ruby
2626

2727
RailsEventStore::Client.new(
28-
dispatcher: RailsEventStore::ImmediateAsyncDispatcher.new(scheduler: RubyEventStore::Outbox::SidekiqScheduler.new),
28+
dispatcher: RailsEventStore::ImmediateDispatcher.new(scheduler: RubyEventStore::Outbox::SidekiqScheduler.new),
2929
...
3030
)
3131
```

contrib/ruby_event_store-protobuf/spec/protobuf_integration_spec.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ module RubyEventStore
2727
mapper: Protobuf::Mappers::Protobuf.new,
2828
dispatcher:
2929
ComposedDispatcher.new(
30-
ImmediateAsyncDispatcher.new(scheduler: RailsEventStore::ActiveJobScheduler.new(serializer: NULL)),
30+
ImmediateDispatcher.new(scheduler: RailsEventStore::ActiveJobScheduler.new(serializer: NULL)),
3131
Dispatcher.new
3232
)
3333
)
File renamed without changes.

contrib/ruby_event_store-sidekiq_scheduler/spec/async_handler_helpers_spec.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ def perform(event)
4646
specify "Sidekiq::Worker without ActiveJob that requires serialization" do
4747
event_store =
4848
RailsEventStore::Client.new(
49-
dispatcher: ImmediateAsyncDispatcher.new(scheduler: SidekiqScheduler.new(serializer: YAML))
49+
dispatcher: ImmediateDispatcher.new(scheduler: SidekiqScheduler.new(serializer: YAML))
5050
)
5151
ev = RubyEventStore::Event.new
5252
Sidekiq::Testing.fake! do
File renamed without changes.
File renamed without changes.

rails_event_store/spec/async_handler_helpers_spec.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ def perform(_event)
5959
let(:another_event_store) { RailsEventStore::Client.new }
6060
let(:json_event_store) do
6161
RailsEventStore::Client.new(
62-
dispatcher: RubyEventStore::ImmediateAsyncDispatcher.new(scheduler: ActiveJobScheduler.new(serializer: JSON))
62+
dispatcher: RubyEventStore::ImmediateDispatcher.new(scheduler: ActiveJobScheduler.new(serializer: JSON))
6363
)
6464
end
6565
let(:application) { instance_double(Rails::Application) }

ruby_event_store/lib/ruby_event_store.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@
3737
require_relative "ruby_event_store/batch_enumerator"
3838
require_relative "ruby_event_store/correlated_commands"
3939
require_relative "ruby_event_store/link_by_metadata"
40-
require_relative "ruby_event_store/immediate_async_dispatcher"
40+
require_relative "ruby_event_store/immediate_dispatcher"
4141
require_relative "ruby_event_store/composed_dispatcher"
4242
require_relative "ruby_event_store/version"
4343
require_relative "ruby_event_store/instrumented_repository"

ruby_event_store/lib/ruby_event_store/immediate_async_dispatcher.rb renamed to ruby_event_store/lib/ruby_event_store/immediate_dispatcher.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
# frozen_string_literal: true
22

33
module RubyEventStore
4-
class ImmediateAsyncDispatcher
4+
class ImmediateDispatcher
55
def initialize(scheduler:)
66
@scheduler = scheduler
77
end

ruby_event_store/spec/client_spec.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -937,7 +937,7 @@ def self.event_type
937937
Client.new(
938938
repository: InMemoryRepository.new(serializer: serializer),
939939
dispatcher:
940-
ImmediateAsyncDispatcher.new(
940+
ImmediateDispatcher.new(
941941
scheduler: ScheduledWithSerialization.new(serializer: serializer)
942942
)
943943
)
@@ -959,7 +959,7 @@ def self.event_type
959959
Client.new(
960960
repository: InMemoryRepository.new(serializer: serializer_1),
961961
dispatcher:
962-
ImmediateAsyncDispatcher.new(
962+
ImmediateDispatcher.new(
963963
scheduler: ScheduledWithSerialization.new(serializer: serializer_2)
964964
)
965965
)

0 commit comments

Comments
 (0)