1 files changed, 7 insertions, 4 deletions
diff --git a/pylon.lua b/pylon.lua
index 02c9b2d..f00faa6 100644
--- a/pylon.lua
+++ b/pylon.lua
@@ -20,9 +20,12 @@ function BasePylon.log(self, ...)
 	if self.debug then print(self.name, ...) end end
 function BasePylon.run(self)
 	self.cq = cqueues.new()
-	self:_connect()
-	self.cq:wrap(self.recving, self)
-	self.cq:wrap(self.sending, self)
-	print(self.name, self.cq:loop()) end
+	self.cq:wrap(function()
+		self:_connect()
+		self.cq:wrap(self.recving, self)
+		self.cq:wrap(self.sending, self)
+	end)
+	print(self.name, self.cq:loop())
+end
 return BasePylon