Skip to content

Add sync historical_data_streaming(), address PR #384 feedback #385

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Merged
wboayue merged 3 commits into from
Jan 31, 2026
Merged

Add sync historical_data_streaming(), address PR #384 feedback #385

wboayue merged 3 commits into from
Jan 31, 2026

Conversation

@wboayue
Copy link
Owner

@wboayue wboayue commented Jan 31, 2026

Summary

  • Add blocking HistoricalDataStreamingSubscription with next/try_next/next_timeout methods
  • Add Client::historical_data_streaming() for sync API
  • Remove HistoricalEnd variant from HistoricalBarUpdate enum (PR Add historical_data_streaming() with keepUpToDate=true support #384 feedback)
  • Fix doc example imports to use prelude types
  • Replace fragile contains() test assertions with field index checks
  • Export previously ignored doctest

@wboayue
Add sync historical_data_streaming(), address PR #384 feedback
9996c2a 
- Add blocking HistoricalDataStreamingSubscription with next/try_next/next_timeout
- Add Client::historical_data_streaming() for sync API
- Remove HistoricalEnd variant from HistoricalBarUpdate enum
- Fix doc example imports to use prelude types
- Replace fragile contains() test assertions with field index checks
- Remove unnecessary #[cfg(feature = "async")] from decoder
@wboayue
Export historical_data_streaming doctest (ignore -> no_run)
7644388
@wboayue
Bump version to 2.7.0
47e100d
@wboayue wboayue merged commit 3943eb8 into main Jan 31, 2026
5 checks passed
@wboayue wboayue deleted the feature/sync-historical-data-streaming branch January 31, 2026 05:54
AdAstraPerAsperaMX pushed a commit to AdAstraPerAsperaMX/subscribe_to_group_events that referenced this pull request Feb 4, 2026
@wboayue @AdAstraPerAsperaMX
Add sync historical_data_streaming(), address PR wboayue#384 feedback (…
cf85397 
…wboayue#385)

* Add sync historical_data_streaming(), address PR wboayue#384 feedback

- Add blocking HistoricalDataStreamingSubscription with next/try_next/next_timeout
- Add Client::historical_data_streaming() for sync API
- Remove HistoricalEnd variant from HistoricalBarUpdate enum
- Fix doc example imports to use prelude types
- Replace fragile contains() test assertions with field index checks
- Remove unnecessary #[cfg(feature = "async")] from decoder

* Export historical_data_streaming doctest (ignore -> no_run)

* Bump version to 2.7.0
AdAstraPerAsperaMX pushed a commit to AdAstraPerAsperaMX/subscribe_to_group_events that referenced this pull request Feb 7, 2026
@wboayue @AdAstraPerAsperaMX
Add sync historical_data_streaming(), address PR wboayue#384 feedback (…
d727fa3 
…wboayue#385)

* Add sync historical_data_streaming(), address PR wboayue#384 feedback

- Add blocking HistoricalDataStreamingSubscription with next/try_next/next_timeout
- Add Client::historical_data_streaming() for sync API
- Remove HistoricalEnd variant from HistoricalBarUpdate enum
- Fix doc example imports to use prelude types
- Replace fragile contains() test assertions with field index checks
- Remove unnecessary #[cfg(feature = "async")] from decoder

* Export historical_data_streaming doctest (ignore -> no_run)

* Bump version to 2.7.0
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

No reviews

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

1 participant

@wboayue