titanfe.apps.brick_runner.output.consumer module

a Consumer represents a connection made to the output server

class titanfe.apps.brick_runner.output.consumer.Consumer(port_name, brick_instance_id, connection)

Bases: object

wrap incoming connections and handle sending packets

async close_connection()

async is_receptive()

async listen()

wait for packet requests, set disconnected-Event if the connection gets closed

async send(packet)

send a packet