File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
lib/concurrent/actor/utils Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -12,14 +12,14 @@ module Utils
12
12
# @yieldparam [Integer] index of the worker, usually used in its name
13
13
# @yieldreturn [Reference] the reference of newly created worker
14
14
# @example
15
- # class Worker < Concurrent::Actor::Utils::AbstractWorker
16
- # def work (message)
15
+ # class Worker < Concurrent::Actor::RestartingContext
16
+ # def on_message (message)
17
17
# p message * 5
18
18
# end
19
19
# end
20
20
#
21
- # pool = Concurrent::Actor::Utils::Pool.spawn! 'pool', 5 do |balancer, index|
22
- # Worker.spawn name: "worker-#{index}", supervise: true, args: [balancer ]
21
+ # pool = Concurrent::Actor::Utils::Pool.spawn! 'pool', 5 do |index|
22
+ # Worker.spawn name: "worker-#{index}", supervise: true, args: []
23
23
# end
24
24
#
25
25
# pool << 'asd' << 2
You can’t perform that action at this time.
0 commit comments