Skip to content

feat(pubsub): implement into_stream for a Session#4590

Merged
haphungw merged 8 commits intogoogleapis:mainfrom
haphungw:session-futures-stream
Feb 9, 2026
Merged

feat(pubsub): implement into_stream for a Session#4590
haphungw merged 8 commits intogoogleapis:mainfrom
haphungw:session-futures-stream

Conversation

@haphungw
Copy link
Copy Markdown
Contributor

@haphungw haphungw commented Feb 6, 2026

Allow Session to be used as a futures::Stream. This enables the use of streaming primitives for message processing.
This feature is gated behind unstable-stream to maintain API stability.

Fixes #4574

@product-auto-label product-auto-label bot added the api: pubsub Issues related to the Pub/Sub API. label Feb 6, 2026
@codecov
Copy link
Copy Markdown

codecov bot commented Feb 6, 2026

Codecov Report

✅ All modified and coverable lines are covered by tests.
✅ Project coverage is 95.01%. Comparing base (3d9ca94) to head (210c498).
⚠️ Report is 4 commits behind head on main.

Additional details and impacted files
@@            Coverage Diff             @@
##             main    #4590      +/-   ##
==========================================
- Coverage   95.02%   95.01%   -0.01%     
==========================================
  Files         195      195              
  Lines        7458     7464       +6     
==========================================
+ Hits         7087     7092       +5     
- Misses        371      372       +1     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

@haphungw haphungw force-pushed the session-futures-stream branch from b793089 to 5af3de9 Compare February 6, 2026 19:19
@haphungw haphungw changed the title feat(pubsub): implement into_stream for a Session feat(pubsub): implement into_stream for a Session Feb 6, 2026
@haphungw haphungw marked this pull request as ready for review February 6, 2026 19:38
@haphungw haphungw requested a review from a team February 6, 2026 19:38
Copy link
Copy Markdown
Member

@dbolduc dbolduc left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The code all looks good.

  • we definitely need to exercise the new feature in our CI
  • we should document the new feature
  • the tests could be cleaned up a bit

@haphungw haphungw force-pushed the session-futures-stream branch 2 times, most recently from c46d369 to c1e4461 Compare February 6, 2026 22:17
Copy link
Copy Markdown
Member

@dbolduc dbolduc left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Just the docs thing, then I think we are good to go

@haphungw haphungw force-pushed the session-futures-stream branch from c1e4461 to 210c498 Compare February 9, 2026 18:13
@haphungw haphungw merged commit a00cd10 into googleapis:main Feb 9, 2026
34 checks passed
@haphungw haphungw deleted the session-futures-stream branch April 4, 2026 00:16
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

api: pubsub Issues related to the Pub/Sub API.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Session should be usable as a futures::Stream

2 participants