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

add Stream.asyncPush api #3277

Merged
merged 12 commits into from
Jul 19, 2024
Merged

add Stream.asyncPush api #3277

merged 12 commits into from
Jul 19, 2024

Commits on Jul 18, 2024

  1. add Stream.asyncPush api

    @tim-smart
    tim-smart committed Jul 18, 2024
    Configuration menu
    Copy the full SHA
    bc8682b View commit details
    Browse the repository at this point in the history

  2. use asyncPush for fromEventListener

    @tim-smart
    tim-smart committed Jul 18, 2024
    Configuration menu
    Copy the full SHA
    e749b73 View commit details
    Browse the repository at this point in the history

  3. move push ops to emit module

    @tim-smart
    tim-smart committed Jul 18, 2024
    Configuration menu
    Copy the full SHA
    c33339b View commit details
    Browse the repository at this point in the history

  4. use DefaultChunkSize as default buffer size

    @tim-smart
    tim-smart committed Jul 18, 2024
    Configuration menu
    Copy the full SHA
    70743cb View commit details
    Browse the repository at this point in the history

  5. use asyncPush default bufferSize in fromEventListener

    @tim-smart
    tim-smart committed Jul 18, 2024
    Configuration menu
    Copy the full SHA
    68e09a3 View commit details
    Browse the repository at this point in the history

  6. cleanup end channel

    @tim-smart
    tim-smart committed Jul 18, 2024
    Configuration menu
    Copy the full SHA
    cbbf356 View commit details
    Browse the repository at this point in the history

  7. .fromEventListener bufferSize

    @tim-smart
    tim-smart committed Jul 18, 2024
    Configuration menu
    Copy the full SHA
    ad47c3f View commit details
    Browse the repository at this point in the history

  8. default to unbounded buffer

    @tim-smart
    tim-smart committed Jul 18, 2024
    Configuration menu
    Copy the full SHA
    defd4f3 View commit details
    Browse the repository at this point in the history

  9. try drain buffer completely on each iteration

    @tim-smart
    tim-smart committed Jul 18, 2024
    Configuration menu
    Copy the full SHA
    65bab23 View commit details
    Browse the repository at this point in the history

  10. simplify buffer

    @tim-smart
    tim-smart committed Jul 18, 2024
    Configuration menu
    Copy the full SHA
    cbe33dd View commit details
    Browse the repository at this point in the history

  11. tweak emit.array

    @tim-smart
    tim-smart committed Jul 18, 2024
    Configuration menu
    Copy the full SHA
    e1364d0 View commit details
    Browse the repository at this point in the history

Commits on Jul 19, 2024

  1. use scheduler instead of queueMicrotask

    @tim-smart
    tim-smart committed Jul 19, 2024
    Configuration menu
    Copy the full SHA
    c4f1c3e View commit details
    Browse the repository at this point in the history