core:async fixes
This commit is contained in:
parent
5c2126805d
commit
230594e98e
2 changed files with 5 additions and 5 deletions
|
@ -86,7 +86,7 @@
|
||||||
|
|
||||||
(deftest test-util-async ()
|
(deftest test-util-async ()
|
||||||
(async:init)
|
(async:init)
|
||||||
(let ((tsk (async:make-task)))
|
(let ((tsk (async:make-task :startup (lambda (&rest args) (sleep 0.01)))))
|
||||||
(== (async:status tsk) :new)
|
(== (async:status tsk) :new)
|
||||||
(async:start tsk)
|
(async:start tsk)
|
||||||
(== (async:status tsk) :running)
|
(== (async:status tsk) :running)
|
||||||
|
|
|
@ -38,10 +38,10 @@
|
||||||
until (eq msg +quit-message+)
|
until (eq msg +quit-message+)
|
||||||
do (funcall handle-message tsk msg))
|
do (funcall handle-message tsk msg))
|
||||||
(sb-sys:interactive-interrupt (e)
|
(sb-sys:interactive-interrupt (e)
|
||||||
(format t "~&async:standard-job: ~a~%" e)))))
|
(format t "~&async:standard-job: ~a~%" e)))
|
||||||
|
(data tsk)))
|
||||||
(setf (status tsk) :done)
|
(setf (status tsk) :done)
|
||||||
(funcall teardown tsk)
|
(funcall teardown tsk))))
|
||||||
(data tsk))))
|
|
||||||
|
|
||||||
;;;; task class and related functions / methods
|
;;;; task class and related functions / methods
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue