diff --git a/fstream-server.py b/fstream-server.py
index 0863d68..2be2784 100644
--- a/fstream-server.py
+++ b/fstream-server.py
@@ -107,7 +107,7 @@ class outThread(threading.Thread):
 	def run(self):
 		try:
 			while True:
-				data = self.queue.get()
+				data = self.queue.get(timeout=15)
 				if type(data) == tuple:
 					data[0](*data[1],**data[2])
 					if data[0] == self.closeThread: return