Running the client in background about cryptoxlib-aio HOT 4 CLOSED

Hi @bastienjalbert ,
you are probably after a construct like this:

async def main_loop():
    while True:
        toto()
        tada()
        await asyncio.sleep(1) # sleep asynchronously for 1 sec

async def run():
    client = CryptoXLib.create_aax_client(api_key, sec_key)
    client.compose_subscriptions(...)

        await asyncio.gather(*[
            client.start_websockets(),
            main_loop()
        ])

    await client.close()

if __name__ == "__main__":
    async_run(run())

Have a look at examples/ws_subscriptions.py.

from cryptoxlib-aio.

Thank you @nardew, appreciate that !

Is there any way to prevent main_loop() to be executed (like waitFor) until the client.start_websockets() has been "launched" ?
Since toto() or tada() may push orders on the market, I would like to monitoring them through the compose_subscriptions callback, but the websockets subscription / start looks slower then my main_loop(). I cannot put a While True: in the main_loop because toto and tada need somehow synchronous. In reality it's only the last step of tada() who need to do some stuff asynchronously (like checking orders status).

I think I may need multi loop or multi threading to achieve that ...

from cryptoxlib-aio.

I am not quite sure what is the ultimate goal but if you need to make sure toto and tada are called only after the streams are initiated, then you can

i) add toto and tada directly into the websocket callback
ii) have a variable which is set in the websocket callback and then have a check for the variable in the main loop

from cryptoxlib-aio.

Since there was not follow up in the past month, I am closing the thread. Re-open if needed.

from cryptoxlib-aio.