Fix for reading an empty string from the zmq firehose

eyeonus · Sep 4, 2014 · e1b7c7a · e1b7c7a
1 parent 9627651
commit e1b7c7a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/emdn/firehose.py b/emdn/firehose.py
@@ -72,7 +72,9 @@ def _read():
 			def _poll(timeout):
 				return self.__socket.poll(timeout)
 			def _read():
-				return self.__socket.recv_string()
+				result = self.__socket.recv_string()
+				if not result: raise EOFError()
+				return result
 
 			# All ZMQ operations are done through a Context,
 			# so use one we're given or create one for ourselves.