self.socket = self.context.socket(zmq.PUB)

        self.socket.connect('tcp://127.0.0.1:9203')  #todo: tie to :collectorZmq in graph

        # old version used: 'tcp://%s:%s' % (service.host, service.port)

    async def send(self, client: str, session: str, settings: DeviceSettings):

        msg = toCollectorJson(client, session, settings).encode('utf8')

        await self.socket.send_multipart([b'setAttr', msg])

_sender = _Sender()

sendToCollector = _sender.send

        sock.bind('tcp://127.0.0.1:9203')

        sock.subscribe(b'setAttr')

        while True:

            [topic, msg] = await sock.recv_multipart()

            if topic != b'setAttr':

                raise ValueError(topic)

            client, clientSession, settings, sendTime = parseJsonMessage(collector.graph, msg)

            collector.setAttrs(client, clientSession, settings, sendTime)

    except:

        traceback.print_exc()

        raise

from lib.background_loop import loop_forever

from light9 import networking

from light9.collector.collector_client_asyncio import sendToCollector

from light9.effect.sequencer.eval_faders import FaderEval

from light9.effect.sequencer.sequencer import Sequencer, StateUpdate

from light9.run_local import log

RATE = 20

async def changes():

    #@metrics('computeAndSend').time() # needs rework with async

    async def update(first_run):

        ds = faders.computeOutput()

        await sendToCollector('effectSequencer', session='0', settings=ds)

    app = Starlette(

        debug=True,

        routes=[

            Route('/updates', endpoint=send_page_updates),

        ],