跟进修改

Author: sumneko

script/brave/brave.lua

@@ -1,5 +1,6 @@
 local channel = require 'bee.channel'
 local select = require 'bee.select'
+local thread = require 'bee.thread'
 
 local function channel_init(chan)
     local selector = select.create()
@@ -9,11 +10,14 @@ end
 
 local function channel_bpop(ctx)
     local selector, chan = ctx[1], ctx[2]
-    for _ in selector:wait() do
-        local r = table.pack(chan:pop())
-        if r[1] == true then
-            return table.unpack(r, 2)
+    while true do
+        for _ in selector:wait() do
+            local r = table.pack(chan:pop())
+            if r[1] == true then
+                return table.unpack(r, 2)
+            end
         end
+        thread.sleep(10)
     end
 end
 

script/meta/bee/thread.lua

@@ -3,7 +3,7 @@
 ---@class bee.thread
 local thread = {}
 
----@param time number
+---@param time integer
 function thread.sleep(time) end
 
 ---@param name string
@@ -15,7 +15,10 @@ function thread.channel(name) end
 
 ---@param script string
 ---@return bee.thread.thread
-function thread.thread(script) end
+function thread.create(script) end
+
+---@return string?
+function thread.errlog() end
 
 ---@class bee.thread.channel
 local channel = {}