BinanceWebSocketApiManager.stop_stream() doesn't stop the stream immediately

[ArnoldWolfstein]

Check this or we will delete your issue. (fill in the checkbox with an X like so: [x])

• I have searched for other issues with the same problem or similar feature requests.

Select one:

• Bug
• Feature Request
• Technical Help
• Other

Environment

• Are you using the module on a VPS or other Cloud hosting?
• Are you using the module on a Raspberry Pi?

What kind of internet connection do you have?

cable

Average system load (CPU)

%10

Hardware specification

Operating System? (include version)

• macOS
• Windows
• Linux (include flavour)

Options

• stream_buffer
• process_stream_data

Which endpoint do you connect?

 binance.com

Python Version Requirement

• I am using Python 3.6.1 or above

Exact Python Version?

Python 3.8.1

Pip Version?

pip 21.0.1

Dependencies

UNICORN Binance WebSocket API Version?

1.29.0

Description of your issue

stop_stream() doesn't stop the related stream immediately. As we can see the code just stops restart.

unicorn-binance-websocket-api/unicorn_binance_websocket_api/unicorn_binance_websocket_api_manager.py

Line 3171 in c975d49

def stop_stream(self, stream_id):

So we need to wait till next heartbeat/ping-pong. Maybe this is the design choice but the function name is a little bit confusing then. Maybe we rename it to: stop_restart_stream()? Or we can implement delete_listen_key_by_stream_id() as well as delete_stream_from_stream_list in it? Maybe both? Just a suggestion.

[oliver-zehentleitner]

No it does not just stops a restart.
It also activates a stop request with self.stream_list[stream_id]['stop_request'] = True

[ArnoldWolfstein]

Yes, and when does the stream stop after activating?

[oliver-zehentleitner]

the stream loop in the socket class (own threads) is checking if there is a new request every round.

as mentioned here i want to try a new way to stop streams with loop.close().

[oliver-zehentleitner]

implementing delete_listen_key_by_stream_id() makes sense i guess!

delete_stream_from_stream_list() is not good, because it contains statistics that can help debugging and maybe devs want still have it available.We can implement a frequent_check that cleans the oldest inactive streams if theere are more 1000 entries on the stack.

[ArnoldWolfstein]

Yeah, makes sense: delete_listen_key_by_stream_id() should be enough.

[oliver-zehentleitner]

Just for documentation: #137 depends on the same fix.

[oliver-zehentleitner]

I dont know whats the right or working way to solve this. Has someone an idea or a hint?

[ebp-z]

I dont know whats the right or working way to solve this. Has someone an idea or a hint?

since it awaits here until data is arrived or connection is closed:

unicorn-binance-websocket-api/unicorn_binance_websocket_api/unicorn_binance_websocket_api_connection.py

Line 290 in 1e57327

received_data_json = await self.manager.websocket_list[self.stream_id].recv()

you can close websocket or use wait_for

[oliver-zehentleitner]

@ebp-z thanks for the hint. using wait_for() has led to restart of the socket after each timeout. i tested wit loop.run_until_complete() and loop.run_forever().

But i found out now, that the loop.stop() which i tryed in the past, is working with loop.run_forever() but not with loop.run_until_complete() what we used till now. i switched it and stop() works now :)

Thanks you!