Merge pull request #20 from learno/kill

add levent.kill(co)

levent/exceptions.lua

@@ -29,10 +29,16 @@ function DnsError:__tostring()
     return "DnsError"
 end
 
+local KillError = class("KillError", BaseException)
+function KillError:__tostring()
+    return "KillError"
+end
+
 local all = {}
 all.BaseException = BaseException
 all.CancelWaitError = CancelWaitError 
 all.DnsError = DnsError
+all.KillError = KillError
 function all.is_exception(exception)
     return class.isinstance(exception, BaseException)
 end

levent/hub.lua

@@ -60,7 +60,9 @@ function Hub:throw(co, exception)
 end
 
 function Hub:handle_error(co, msg)
-    print("error:", co, msg)
+    if not class.isinstance(msg, exceptions.KillError) then
+        print("error:", co, msg)
+    end
 end
 
 function Hub:_yield(waiter)

levent/levent.lua

@@ -4,9 +4,14 @@
 --]]
 local hub        = require "levent.hub"
 local coroutines = require "levent.coroutines"
+local exceptions = require "levent.exceptions"
+
+local kill_error = exceptions.KillError.new()
 
 local levent = {}
 
+levent.kill_error = kill_error
+
 function levent.now()
     return hub.loop:now()
 end
@@ -53,6 +58,11 @@ levent.check_coroutine = coroutines.check
 function levent.spawn(f, ...)
     local co = coroutines.create(f)
     hub.loop:run_callback(assert_resume, co, ...)
+    return co
+end
+
+function levent.kill(co)
+    hub.loop:run_callback(hub.throw, hub, co, kill_error)
 end
 
 function levent.start(f, ...)