fix(copas) switch to pause instead of sleep

xHasKx · Oct 26, 2022 · ed710fc · ed710fc
1 parent 1e212c7
commit ed710fc
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/examples/copas-example.lua b/examples/copas-example.lua
@@ -29,7 +29,7 @@ local ping = mqtt.client{
 			-- code below does both, sleeping, and writing (implicit in 'publish')
 			copas.addthread(function()
 				for i = 1, num_pings do
-					copas.sleep(delay)
+					copas.pause(delay)
 					print("ping", i)
 					assert(self:publish{ topic = "luamqtt/copas-ping/"..suffix, payload = "ping"..i, qos = 1 })
 				end

diff --git a/mqtt/client.lua b/mqtt/client.lua
@@ -898,7 +898,7 @@ end
 --         if not my_client then
 --             return -- exiting, client was destroyed
 --         end
---         copas.sleep(my_client:check_keep_alive())
+--         copas.pause(my_client:check_keep_alive())
 --     end
 -- end)
 function Client:check_keep_alive()

diff --git a/mqtt/loop/copas.lua b/mqtt/loop/copas.lua
@@ -41,7 +41,7 @@ function _M.add(cl)
 		while client_registry[cl] do
 			local next_check = cl:check_keep_alive()
 			if next_check > 0 then
-				copas.sleep(next_check)
+				copas.pause(next_check)
 			end
 		end
 	end, cl.opts.id .. ":keep_alive")
@@ -56,7 +56,7 @@ function _M.add(cl)
 				copas.wakeup(timer)
 			else
 				if timeout > 0 then
-					copas.sleep(timeout)
+					copas.pause(timeout)
 				end
 			end
 		end

diff --git a/tests/spec/08-copas_spec.lua b/tests/spec/08-copas_spec.lua
@@ -58,7 +58,7 @@ describe("copas connector", function()
 						return
 					end
 					if timeout > 0 then
-						copas.sleep(timeout)
+						copas.pause(timeout)
 					end
 				end
 			end)