some useful functions

src/mysc/thread_utils.py

@@ -1,6 +1,7 @@
 # -*- coding: utf-8 -*-
 import threading
 import wx
+from pubsub import pub
 from twython import TwythonRateLimitError
 import time
 
@@ -19,3 +20,14 @@ def call_threaded(func, *args, **kwargs):
  thread.daemon = True
  thread.start()
  return thread
+
+def stream_threaded(func, *args, **kwargs):
+ def new_func(*a, **k):
+  try:
+   func(*a, **k)
+  except:
+   pub.sendMessage("streamError")
+ thread = threading.Thread(target=new_func, args=args, kwargs=kwargs)
+ thread.daemon = True
+ thread.start()
+ return thread