Skip to content

Conversation

@Marenz
Copy link
Contributor

@Marenz Marenz commented Sep 25, 2024

No description provided.

@Marenz Marenz requested review from a team as code owners September 25, 2024 09:51
@github-actions github-actions bot added part:tests Affects the unit, integration and performance (benchmarks) tests part:dispatcher labels Sep 25, 2024
@github-actions github-actions bot added the part:docs Affects the documentation label Sep 26, 2024
@Marenz Marenz changed the title Add method to get a callback before connecting to the stream Client.stream: Raise exception on connection loss Sep 26, 2024
Copy link
Contributor

@llucax llucax left a comment

Choose a reason for hiding this comment

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

I'm fine with merging this as is and update when the client-base gets any needed changes.

Comment on lines +212 to +213
# pylint: disable=protected-access
if broadcaster is not None and broadcaster._channel.is_closed:
Copy link
Contributor

@llucax llucax Sep 26, 2024

Choose a reason for hiding this comment

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

This is not nice. We should add a broadcaster.is_running() or something. I think there is no one day that goes by without me thinking "we need to implement this using core.asyncio.Service". 😬

After I finish with the microgrid API client... 🙏

@Marenz Marenz added this pull request to the merge queue Sep 26, 2024
Merged via the queue into frequenz-floss:v0.x.x with commit 66c64a9 Sep 26, 2024
14 checks passed
@Marenz Marenz deleted the streamstream branch September 26, 2024 13:44
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

part:dispatcher part:docs Affects the documentation part:tests Affects the unit, integration and performance (benchmarks) tests

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants