Skip to content
New issue

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

#

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

Already on GitHub? # to your account

Jump to bottom

Multi emitOn has a hard-coded limit that yields small request batches of 16 elements #1758

Closed
jponge opened this issue Dec 5, 2024 · 0 comments · Fixed by #1761
Closed

Multi emitOn has a hard-coded limit that yields small request batches of 16 elements #1758

jponge opened this issue Dec 5, 2024 · 0 comments · Fixed by #1761
Assignees
@jponge
Labels
enhancement New feature or request

Comments

@jponge
Copy link
Member

jponge commented Dec 5, 2024

See quarkusio/quarkus#36177 for the related discussion.

We should revisit this hard-coded limit and at the very least make it configurable.
@jponge jponge added the enhancement New feature or request label Dec 5, 2024
jponge added a commit to jponge/smallrye-mutiny that referenced this issue Dec 9, 2024
@jponge
feat(operators)!: introduce a buffer size parameter to Multi::emitOn
2d225a8 
The operator was previously using a hard-coded buffer size of 16 elements which was
also used to batch upstream demand.
This was a performance bottleneck for large streams as observed in the field.

The existing Multi::emitOn(executor) method remains, but it now uses
Infrastructure.getBufferSizeS() as a default buffer size instead of 16.

We do not expect existing usages of emitOn(executor) to be affected by this internal change.

Fixes: smallrye#1758
See-Also: quarkusio/quarkus#36177
@jponge jponge mentioned this issue Dec 9, 2024
Merged
@jponge jponge mentioned this issue Feb 11, 2025
Closed
# for free to join this conversation on GitHub. Already have an account? # to comment
Assignees

@jponge jponge

Labels
enhancement New feature or request
Projects
None yet
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

feat(operators)!: introduce a buffer size parameter to Multi::emitOn jponge/smallrye-mutiny
1 participant
@jponge