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.

Sign up for GitHub

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

Jump to bottom

pekko: source based on BlockingQueue #1676

Merged
merged 1 commit into from
Jul 30, 2024
Merged

pekko: source based on BlockingQueue #1676

merged 1 commit into from
Jul 30, 2024

Commits on Jul 30, 2024

  1. pekko: source based on BlockingQueue 

    Add helper to create a source that is based on a Java
BlockingQueue implementation. This can be used as an
alternative to Pekko's BoundedSourceQueue when more
control of the queue is desirable. If the queue is full
it can be set to either drop newly arriving values or
older values that are already in the queue.
    @brharrington
    brharrington committed Jul 30, 2024
    Configuration menu
    Copy the full SHA
    2265faf View commit details
    Browse the repository at this point in the history