def _buffer_recv_worker(rt_client, nchan):
 try:
  for raw_buffer in rt_client.raw_buffers(nchan):
   rt_client._push_raw_buffer(raw_buffer)
 except RuntimeError as err:
  rt_client._recv_thread = None
  print(('Buffer receive thread stopped: %s' % err))

def _buffer_recv_worker ( rt_client , nchan ) : try : for raw_buffer in rt_client . raw_buffers ( nchan ) : rt_client . _push_raw_buffer ( raw_buffer ) except RuntimeError as err : rt_client . _recv_thread = None print ( ( 'Buffer receive thread stopped: %s' % err ) )
worker thread that constantly receives buffers .