Skip to content
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.

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

Add Actor, external runner and fix flows publisher issues #81

Merged
merged 4 commits into from
Jan 8, 2025

Conversation

emil-bar
Copy link
Contributor

@emil-bar emil-bar commented Jan 3, 2025

Closes #82

@emil-bar emil-bar force-pushed the fix-reactive-publisher-in-flows branch from 6453b3b to 3b94895 Compare January 7, 2025 14:40
@emil-bar emil-bar changed the title WIP Add Actor Add Actor Jan 7, 2025
@emil-bar emil-bar changed the title Add Actor Add Actor, external runner and fix flows publisher issues Jan 7, 2025
@emil-bar emil-bar marked this pull request as ready for review January 7, 2025 15:20
@emil-bar emil-bar force-pushed the fix-reactive-publisher-in-flows branch from 3b94895 to a7676f3 Compare January 7, 2025 15:32
* ExternalRunner#runAsync(ThrowingConsumer) for running functions within the scope
*/
public ExternalRunner externalRunner() {
if (externalSchedulerActor == null) {
Copy link
Member

Choose a reason for hiding this comment

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

this needs concurrent access protection

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Done
I used ReentrantLock instead of Synchronized as it's not pinning the thread (at least in used version) https://stackoverflow.com/a/79304473

@adamw adamw merged commit aa4f8a9 into main Jan 8, 2025
2 checks passed
@adamw adamw deleted the fix-reactive-publisher-in-flows branch January 8, 2025 09:48
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.

Fix flows reactive streams publisher
2 participants