[chipkent]

Preview only. This is a draft in the fork showing the exact text of the PR planned for massive-com/client-python. It will be closed, not merged, once the upstream PR is opened.

Fixes #<issue: F1a-delay>

Builds on #20.

connect() sent subscription changes only when its receive loop came round again, after the next message or the 1-second receive timeout. On a quiet feed, a subscribe() took up to a second to reach the server.

• Each connection now has one task that sends subscription changes. It starts after authentication by sending the whole scheduled set.
• subscribe(), unsubscribe() and unsubscribe_all() wake it through loop.call_soon_threadsafe(), which never blocks the caller.
• As the only sender, it never interleaves messages, and it merges a burst of changes into one subscribe and one unsubscribe message.
• The receive loop still checks schedule_resub on every turn, so setting scheduled_subs and schedule_resub directly still works.
• Sending while another coroutine waits in recv() is safe in websockets 14.0 through 17.3, the current release; the commit message cites the lines.

Throughput is unchanged: with a local server sending 20 trades per message, the median time per message is within 1% of master on 3.10 and 3.14 (benchmark script available on request).

Tests

• New test_sender.py: with the receive timeout removed, a change made from another thread still reaches an idle connection (fails on master), and direct writes to scheduled_subs still work.
• make test and make lint pass on 3.10 and 3.14.

[coderabbitai]

Important

Draft PR not reviewed

Draft PRs are not automatically reviewed by default.

• Trigger a manual review

To automatically review draft PRs, update your CodeRabbit configuration:

reviews:
  auto_review:
    drafts: true

• Autofix · Keep fixing CodeRabbit findings and required CI, and resolving merge conflicts

_{Comment @coderabbitai help to get the list of available commands.}