Skip to content

[Brook] Added a default type to Stream reads. - #334

Closed
moetemp wants to merge 2 commits into
moe/brook/v3/p11-shutdown-drainfrom
moe/brook/v3/p12-default-read-type
Closed

moetemp wants to merge 2 commits into
moe/brook/v3/p11-shutdown-drainfrom
moe/brook/v3/p12-default-read-type

Conversation

@moetemp

@moetemp moetemp commented Oct 21, 2026

Copy link
Copy Markdown
Owner

What changed?

This PR adds type= to subscribe() on ClientStream and Activity Streams. Topics with no type decode as that type. A Topic from topic(name, type=...) keeps its own type.

Why?

A reader of many Topics of one type had to declare each Topic before the read (DECISIONS.md S29).

How did you test it?

pytest tests/contrib/streams/test_facade.py, with the in-memory stand-in for the extension.

  • Unit Tests
  • Staging
  • End to End Tests

A reader of many Topics of one type had to declare each Topic. subscribe(type=T) decodes the Topics with no type as T, and a typed Topic keeps its own type.
@moetemp

moetemp commented Oct 25, 2026

Copy link
Copy Markdown
Owner Author

Closing as stale. This layer is folded into the v5 tip, #365, and the upstream review uses a fresh series instead. Plan: https://www.notion.so/4048fc567738814990b7c796ac28fe3f

@moetemp moetemp closed this Oct 25, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant