Websocket freezing - Githubissues

Hello! I noticed that after around 42 seconds my application freezes

I can get rid of the error by removing the line await time.sleep(0.1) in my code. But in my actual trading bot there is some math that needs to be done and the sleep is command is replacing it.

Here's my code to illustrate the issue:

import asyncio
import time

from binance import BinanceSocketManager, AsyncClient

async def socket():
    messages = 0
    streams = ["ethbtc@bookTicker", "btcusdt@trade", "ethusdt@bookTicker"]
    start_time = time.time()

    client = await AsyncClient.create()
    bm = BinanceSocketManager(client)

    multi_socket = bm.multiplex_socket(streams)

    async with multi_socket as ms:
        while True:
            messages += 1
            msg = await ms.recv()

            time.sleep(0.1) # This illustrates some math that would be done

            # print current message's stream and the total amount of messages received
            message = msg["stream"]
            msg = f"\rMessages: {messages} Message: {message} Time: {float(time.time()-start_time)}       "
            print(msg, end="")

if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(socket())

Expected behavior Expecting a continuous stream of messages. Instead stream freezes permanently after around 42 second.

Environment (please complete the following information):

Python version: [e.g. 3.9]
OS: Windowns
python-binance version 1.0.12

Note Repost of https://github.com/sammchardy/python-binance/issues/862#issue-894140160 that was supposed to be fixed but wasn't. Switched the following line from the original post. await asyncio.sleep(0.1) to time.sleep(0.1)

I don't know if this makes a difference but in my real application the thread is busy doing math so it isn't something that can be awaited if have understood coroutines correctly.

sammchardy / python-binance

Websocket freezing #908