Skip to content

Commit 103e947

Browse files
committed
refactoring: move the initialization code into a separate function
When the script is long enough to contain multiple function, it's nice to have a function like "main" instead of just a linear flow code. The patch moves the initialization code of the queue module into a separate function.
1 parent 0221f8d commit 103e947

File tree

1 file changed

+21
-17
lines changed

1 file changed

+21
-17
lines changed

queue/init.lua

Lines changed: 21 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -26,26 +26,30 @@ queue = setmetatable({
2626
register_driver = register_driver,
2727
}, { __index = function() print(debug.traceback()) error("Please run box.cfg{} first") end })
2828

29-
if rawget(box, 'space') == nil then
30-
local orig_cfg = box.cfg
31-
box.cfg = function(...)
32-
local result = { orig_cfg(...) }
33-
34-
local abstract = require 'queue.abstract'
35-
for name, val in pairs(abstract) do
36-
rawset(queue, name, val)
29+
local function queue_init()
30+
if rawget(box, 'space') == nil then
31+
local orig_cfg = box.cfg
32+
box.cfg = function(...)
33+
local result = { orig_cfg(...) }
34+
35+
local abstract = require 'queue.abstract'
36+
for name, val in pairs(abstract) do
37+
rawset(queue, name, val)
38+
end
39+
abstract.driver = queue.driver
40+
setmetatable(queue, getmetatable(abstract))
41+
queue.start()
42+
43+
return unpack(result)
3744
end
38-
abstract.driver = queue.driver
39-
setmetatable(queue, getmetatable(abstract))
45+
else
46+
queue = require 'queue.abstract'
47+
queue.register_driver = register_driver
48+
queue.driver = core_drivers
4049
queue.start()
41-
42-
return unpack(result)
4350
end
44-
else
45-
queue = require 'queue.abstract'
46-
queue.register_driver = register_driver
47-
queue.driver = core_drivers
48-
queue.start()
4951
end
5052

53+
queue_init()
54+
5155
return queue

0 commit comments

Comments
 (0)