Skip to content

Commit 6f57449

Browse files
committed
Update strategy names of SetResults to correspond with Pausing commands
1 parent bbd050d commit 6f57449

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

lib/concurrent/actor/behaviour.rb

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -34,18 +34,18 @@ module Behaviour
3434

3535
def self.basic_behaviour_definition
3636
[*base,
37-
*user_messages(:terminate)]
37+
*user_messages(:terminate!)]
3838
end
3939

4040
def self.restarting_behaviour_definition
4141
[*base,
4242
*supervised,
4343
[Behaviour::Supervising, [:reset!, :one_for_one]],
44-
*user_messages(:pause)]
44+
*user_messages(:pause!)]
4545
end
4646

4747
def self.base
48-
[[SetResults, [:terminate]],
48+
[[SetResults, [:terminate!]],
4949
# has to be before Termination to be able to remove children form terminated actor
5050
[RemovesChild, []],
5151
[Termination, []],

lib/concurrent/actor/behaviour/sets_results.rb

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ class SetResults < Abstract
77

88
def initialize(core, subsequent, error_strategy)
99
super core, subsequent
10-
@error_strategy = Match! error_strategy, :just_log, :terminate, :pause
10+
@error_strategy = Match! error_strategy, :just_log, :terminate!, :pause!
1111
end
1212

1313
def on_envelope(envelope)
@@ -19,9 +19,9 @@ def on_envelope(envelope)
1919
rescue => error
2020
log Logging::ERROR, error
2121
case error_strategy
22-
when :terminate
22+
when :terminate!
2323
terminate!
24-
when :pause
24+
when :pause!
2525
behaviour!(Pausing).pause!(error)
2626
when :just_log
2727
# nothing

0 commit comments

Comments
 (0)