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

Stream - GroupWithin - Some changes. #2619

Merged
merged 1 commit into from
Sep 21, 2021

Conversation

diesalbla
Copy link
Contributor

  • Rename the n parameter as outputSize
  • For dequeueN and other internal functions, no need to pass the n parameter since that is just the outputSize parameter of main function.
  • Extract auxiliary toEnding function.
  • Documentation: add some inline documentation, and the scaladoc of the method...

@diesalbla diesalbla force-pushed the groupWithin_refactor branch 2 times, most recently from 33f401b to 21e1d63 Compare September 18, 2021 15:32
- Rename the `n` parameter as `chunkSize`

- For `dequeueN` and other internal functions, no need to pass the `n`
  parameter since that is just the `outputSize` parameter of main function.
- Extract auxiliary `toEnding` function, exit-case to unit or error.
@mpilquist mpilquist merged commit dafd577 into typelevel:main Sep 21, 2021
@diesalbla diesalbla deleted the groupWithin_refactor branch September 24, 2021 09:45
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.

2 participants