diff options
Diffstat (limited to 'test/git/async/test_thread.py')
| -rw-r--r-- | test/git/async/test_thread.py | 19 |
1 files changed, 9 insertions, 10 deletions
diff --git a/test/git/async/test_thread.py b/test/git/async/test_thread.py index 2ea8d1ff..a08c1dc7 100644 --- a/test/git/async/test_thread.py +++ b/test/git/async/test_thread.py @@ -3,28 +3,26 @@ from test.testlib import * from git.async.thread import * from Queue import Queue +import time class TestWorker(WorkerThread): def __init__(self, *args, **kwargs): super(TestWorker, self).__init__(*args, **kwargs) self.reset() - def fun(self, *args, **kwargs): + def fun(self, arg): self.called = True - self.args = args - self.kwargs = kwargs + self.arg = arg return True def make_assertion(self): assert self.called - assert self.args - assert self.kwargs + assert self.arg self.reset() def reset(self): self.called = False - self.args = None - self.kwargs = None + self.arg = None class TestThreads( TestCase ): @@ -36,10 +34,11 @@ class TestThreads( TestCase ): # test different method types standalone_func = lambda *args, **kwargs: worker.fun(*args, **kwargs) - for function in ("fun", TestWorker.fun, worker.fun, standalone_func): - worker.call(function, 1, this='that') + for function in (TestWorker.fun, worker.fun, standalone_func): + worker.inq.put((function, 1)) + time.sleep(0.01) worker.make_assertion() # END for each function type - worker.call('quit') + worker.stop_and_join() |