split try_pop and pop
This commit is contained in:
		| @@ -181,7 +181,7 @@ class URRTMonitor(threading.Thread): | |||||||
|     def stop_buffering(self): |     def stop_buffering(self): | ||||||
|         self._buffering = False |         self._buffering = False | ||||||
|  |  | ||||||
|     def pop_buffer(self): |     def try_pop_buffer(self): | ||||||
|         """ |         """ | ||||||
|         return oldest value in buffer |         return oldest value in buffer | ||||||
|         """ |         """ | ||||||
| @@ -191,6 +191,17 @@ class URRTMonitor(threading.Thread): | |||||||
|             else: |             else: | ||||||
|                 return None |                 return None | ||||||
|  |  | ||||||
|  |     def pop_buffer(self): | ||||||
|  |         """ | ||||||
|  |         return oldest value in buffer | ||||||
|  |         """ | ||||||
|  |         while True: | ||||||
|  |             with self._buffer_lock: | ||||||
|  |                 if len(self._buffer) > 0: | ||||||
|  |                     return self._buffer.pop(0) | ||||||
|  |             time.sleep(0.001) | ||||||
|  |  | ||||||
|  |  | ||||||
|     def get_buffer(self): |     def get_buffer(self): | ||||||
|         """ |         """ | ||||||
|         return a copy of the entire buffer |         return a copy of the entire buffer | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user