pytak.RXWorker

class pytak.RXWorker(queue: Queue | Queue, config: None | SectionProxy | dict, reader: Protocol)

Async receive (input) queue worker.

Reads events from a pytak.protocol_factory() reader and adds them to an rx_queue.

Most implementations use this to drain an RX buffer on a socket.

pytak([asyncio.Protocol]->[pytak.EventReceiver]->[queue.Queue])

__init__(queue: Queue | Queue, config: None | SectionProxy | dict, reader: Protocol) → None

Initialize a RXWorker instance.

Methods

__init__(queue, config, reader)	Initialize a RXWorker instance.
fts_compat()	Apply FreeTAKServer (FTS) compatibility.
handle_data(data)	Handle data (placeholder method, please override).
readcot()	Read CoT from the wire until we hit an event boundary.
run([number_of_iterations])	Run this worker.