Broker which works runs in a separate thread It reads the queue which get blocked if there is no data class level attribute broker which get data from the SDR device reader Once the data in queue, it is read and send to the Central machine

class rfnode.broker.DataBroker

Bases: object

q = <queue.Queue object>

set_rf_sender(sender: Sender) → None

set the sender class which sends the RF data to the Central machine :param sender: The RF sender :type sender: Sender

Returns:

does not return any value

Return type:

None

start()

worker()

loop once the queue is empty this loop block or the thread get blocked await for incoming data to read again