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
1212 # @yieldparam [Integer] index of the worker, usually used in its name
1313 # @yieldreturn [Reference] the reference of newly created worker
1414 # @example
15- # class Worker < Concurrent::Actor::Utils::AbstractWorker
16- # def work (message)
15+ # class Worker < Concurrent::Actor::RestartingContext
16+ # def on_message (message)
1717 # p message * 5
1818 # end
1919 # end
2020 #
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: []
2323 # end
2424 #
2525 # pool << 'asd' << 2
You can’t perform that action at this time.
0 commit comments