[r0h4n0xPota]

[JIRA TICKET]

Changes in this PR

• Added a new StreamProcessingClient (and its async twin) to PyMongo that lets users manage Atlas Stream Processing workspaces directly, instead of having to call runCommand themselves. It wraps the spec'd commands: create, start, stop, drop, getInfo, stats and a custom sample cursor that handles the two-phase start/getMore sample protocol. Connection rules from the spec are enforced (only mongodb://, TLS always on, authSource=admin defaulted), and server errors pass straight through unchanged. All built async-first so the sync version is auto-generated.

Test Plan

Checklist

Checklist for Author

• Did you update the changelog (if necessary)?
• Is there test coverage?
• Is any followup work tracked in a JIRA ticket? If so, add link(s).

Checklist for Reviewer

• Does the title of the PR reference a JIRA Ticket?
• Do you fully understand the implementation? (Would you be comfortable explaining how this code works to someone else?)
• Is all relevant documentation (README or docstring) updated?

[codecov-commenter]

Codecov Report

❌ Patch coverage is 80.93220% with 90 lines in your changes missing coverage. Please review.

Files with missing lines	Patch %	Lines
pymongo/asynchronous/stream_processing.py	76.56%	23 Missing and 22 partials ⚠️
pymongo/synchronous/stream_processing.py	76.56%	23 Missing and 22 partials ⚠️

📢 Thoughts on this report? Let us know!