X-Git-Url: http://vcs.maemo.org/git/?a=blobdiff_plain;f=src%2Futil%2Fconcurrent.py;h=f5f6e1dc0610cf0bbadfa1eba2ad0b4d5f28459f;hb=27937b7f8bf0cfeb891cf14da12c7eab58e5d038;hp=4d314682659557e77d1643ea6ca81f2c04cf10a9;hpb=4a05c23ef23a4c9438704a7320b63f94a4d28f0c;p=gc-dialer diff --git a/src/util/concurrent.py b/src/util/concurrent.py index 4d31468..f5f6e1d 100644 --- a/src/util/concurrent.py +++ b/src/util/concurrent.py @@ -23,7 +23,7 @@ class AsyncTaskQueue(object): def add_async(self, func): self.flush() - a = _AsyncGeneratorTask(self._taskPool, func) + a = AsyncGeneratorTask(self._taskPool, func) self._asyncs.append(a) return a @@ -31,7 +31,7 @@ class AsyncTaskQueue(object): self._asyncs = [a for a in self._asyncs if not a.isDone] -class _AsyncGeneratorTask(object): +class AsyncGeneratorTask(object): def __init__(self, pool, func): self._pool = pool