diff options
Diffstat (limited to 'pylon.lua')
| -rw-r--r-- | pylon.lua | 6 |
1 files changed, 4 insertions, 2 deletions
@@ -1,7 +1,9 @@ local cqueues = require'cqueues' - +local pprint = require 'pprint' local class = require 'r.class' local qw = require 'r.qw' + +local bs = require'bs' local Queue = require 'queue' local BasePylon = class() @@ -25,6 +27,6 @@ function BasePylon.run(self) self.cq:wrap(self.recving, self) self.cq:wrap(self.sending, self) end) - print(self.name, self.cq:loop()) + bs.loop_correctly(self.name, self.cq) end return BasePylon |
