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 flatMap method for collapsing streams into one #4227

Merged
merged 46 commits into from
Apr 9, 2024
Merged

Add flatMap method for collapsing streams into one #4227

merged 46 commits into from
Apr 9, 2024

Commits on Apr 25, 2022

  1. Add flatMap method for collapsing streams into one

    @sleeplesslord
    sleeplesslord committed Apr 25, 2022
    Configuration menu
    Copy the full SHA
    d95055c View commit details
    Browse the repository at this point in the history

Commits on May 5, 2022

  1. Manually handle completion tracking for flatMap

    @sleeplesslord
    sleeplesslord committed May 5, 2022
    Configuration menu
    Copy the full SHA
    d3fba09 View commit details
    Browse the repository at this point in the history

  2. Cancel inner subscriptions when FlatMap is cancelled

    @sleeplesslord
    sleeplesslord committed May 5, 2022
    Configuration menu
    Copy the full SHA
    49fbc2e View commit details
    Browse the repository at this point in the history

  3. Get demand from inner subscription

    @sleeplesslord
    sleeplesslord committed May 5, 2022
    Configuration menu
    Copy the full SHA
    761da4c View commit details
    Browse the repository at this point in the history

  4. Rename method for clarity

    @sleeplesslord
    sleeplesslord committed May 5, 2022
    Configuration menu
    Copy the full SHA
    74bf0b7 View commit details
    Browse the repository at this point in the history

Commits on Nov 26, 2022

  1. Use ArrayDeque for smaller memory footprint

    @sleeplesslord
    sleeplesslord committed Nov 26, 2022
    Configuration menu
    Copy the full SHA
    80141c3 View commit details
    Browse the repository at this point in the history

  2. Request Long.MAX_VALUE from source when downstream requests it

    @sleeplesslord
    sleeplesslord committed Nov 26, 2022
    Configuration menu
    Copy the full SHA
    0082442 View commit details
    Browse the repository at this point in the history

  3. Improve testing and add associativity test

    @sleeplesslord
    sleeplesslord committed Nov 26, 2022
    Configuration menu
    Copy the full SHA
    3219a78 View commit details
    Browse the repository at this point in the history

Commits on Dec 24, 2022

  1. Improve documentation for flatMap

    @sleeplesslord
    sleeplesslord committed Dec 24, 2022
    Configuration menu
    Copy the full SHA
    589296b View commit details
    Browse the repository at this point in the history

  2. Add check for maxConcurrency > 0 in flatMap

    @sleeplesslord
    sleeplesslord committed Dec 24, 2022
    Configuration menu
    Copy the full SHA
    8d0df8e View commit details
    Browse the repository at this point in the history

  3. Use EventLoopCheckingFuture

    @sleeplesslord
    sleeplesslord committed Dec 24, 2022
    Configuration menu
    Copy the full SHA
    a9f6ab4 View commit details
    Browse the repository at this point in the history

  4. Use same executor for FlatMapSubscribers

    @sleeplesslord
    sleeplesslord committed Dec 24, 2022
    Configuration menu
    Copy the full SHA
    9a6d5fc View commit details
    Browse the repository at this point in the history

Commits on Dec 25, 2022

  1. Remove unnecessary executor checks

    @sleeplesslord
    sleeplesslord committed Dec 25, 2022
    Configuration menu
    Copy the full SHA
    9bfcb8a View commit details
    Browse the repository at this point in the history

  2. Use toImmutableList

    @sleeplesslord
    sleeplesslord committed Dec 25, 2022
    Configuration menu
    Copy the full SHA
    87ec0fb View commit details
    Browse the repository at this point in the history

Commits on Dec 29, 2022

  1. Pass SubscriptionOptions into FlatMapSubscriber

    @sleeplesslord
    sleeplesslord committed Dec 29, 2022
    Configuration menu
    Copy the full SHA
    dc7c776 View commit details
    Browse the repository at this point in the history

  2. Cancel properly when getting invalid request

    @sleeplesslord
    sleeplesslord committed Dec 29, 2022
    Configuration menu
    Copy the full SHA
    400d092 View commit details
    Browse the repository at this point in the history

  3. Prevent requesting 0 from upstream

    @sleeplesslord
    sleeplesslord committed Dec 29, 2022
    Configuration menu
    Copy the full SHA
    84c4556 View commit details
    Browse the repository at this point in the history

  4. Flush before requesting to upstream to avoid unnecessary requests

    @sleeplesslord
    sleeplesslord committed Dec 29, 2022
    Configuration menu
    Copy the full SHA
    08cf0ff View commit details
    Browse the repository at this point in the history

  5. Handle Long.MAX_VALUE in FlatMapSubscriber

    @sleeplesslord
    sleeplesslord committed Dec 29, 2022
    Configuration menu
    Copy the full SHA
    2f5cb04 View commit details
    Browse the repository at this point in the history

  6. Prevent pendingSubscriptions from becoming negative

    @sleeplesslord
    sleeplesslord committed Dec 29, 2022
    Configuration menu
    Copy the full SHA
    0155dcc View commit details
    Browse the repository at this point in the history

  7. Rename field and methods for clarity

    @sleeplesslord
    sleeplesslord committed Dec 29, 2022
    Configuration menu
    Copy the full SHA
    d1c4319 View commit details
    Browse the repository at this point in the history

  8. Avoid making unnecessary additional requests when available is MAX

    @sleeplesslord
    sleeplesslord committed Dec 29, 2022
    Configuration menu
    Copy the full SHA
    d2f053d View commit details
    Browse the repository at this point in the history

Commits on Dec 31, 2022

  1. Fix lint

    @sleeplesslord
    sleeplesslord committed Dec 31, 2022
    Configuration menu
    Copy the full SHA
    06f80eb View commit details
    Browse the repository at this point in the history

Commits on Feb 16, 2023

  1. Merge branch 'master' of github.com:line/armeria into flatmap

    @jrhee17
    jrhee17 committed Feb 16, 2023
    Configuration menu
    Copy the full SHA
    0ebe59a View commit details
    Browse the repository at this point in the history

Commits on Feb 23, 2023

  1. Simplify upstream request logic and fix missing upstream requests

    @sleeplesslord
    sleeplesslord committed Feb 23, 2023
    Configuration menu
    Copy the full SHA
    28a1ea2 View commit details
    Browse the repository at this point in the history

  2. Fix stream being completed despite buffer having values

    @sleeplesslord
    sleeplesslord committed Feb 23, 2023
    Configuration menu
    Copy the full SHA
    d7ac1c3 View commit details
    Browse the repository at this point in the history

  3. Complete future exceptionally on error

    @sleeplesslord
    sleeplesslord committed Feb 23, 2023
    Configuration menu
    Copy the full SHA
    44f3920 View commit details
    Browse the repository at this point in the history

  4. Close or abort elements in the buffer when flatMap is cancelled

    @sleeplesslord
    sleeplesslord committed Feb 23, 2023
    Configuration menu
    Copy the full SHA
    ff2b023 View commit details
    Browse the repository at this point in the history

Commits on Feb 24, 2023

  1. Prevent multiple calls to subscription.cancel in FlatMapSubscriber

    @sleeplesslord
    sleeplesslord committed Feb 24, 2023
    Configuration menu
    Copy the full SHA
    6da1473 View commit details
    Browse the repository at this point in the history

Commits on Mar 3, 2023

  1. Improve formatting

    @sleeplesslord
    sleeplesslord committed Mar 3, 2023
    Configuration menu
    Copy the full SHA
    fc5948b View commit details
    Browse the repository at this point in the history

  2. Fix flatMap not completing after last elements are requested

    @sleeplesslord
    sleeplesslord committed Mar 3, 2023
    Configuration menu
    Copy the full SHA
    eff4ccc View commit details
    Browse the repository at this point in the history

  3. Clean up values received after canceling

    @sleeplesslord
    sleeplesslord committed Mar 3, 2023
    Configuration menu
    Copy the full SHA
    8aed68f View commit details
    Browse the repository at this point in the history

  4. Clean up buffer to prevent mistakes

    @sleeplesslord
    sleeplesslord committed Mar 3, 2023
    Configuration menu
    Copy the full SHA
    5a2b058 View commit details
    Browse the repository at this point in the history

  5. Handle multiple calls to cancel as NOP in flat map

    @sleeplesslord
    sleeplesslord committed Mar 3, 2023
    Configuration menu
    Copy the full SHA
    a72d567 View commit details
    Browse the repository at this point in the history

  6. Run cancel through EventExecutor in flat map

    @sleeplesslord
    sleeplesslord committed Mar 3, 2023
    Configuration menu
    Copy the full SHA
    f3fa4a8 View commit details
    Browse the repository at this point in the history

  7. Fix lint

    @sleeplesslord
    sleeplesslord committed Mar 3, 2023
    Configuration menu
    Copy the full SHA
    ca99d0c View commit details
    Browse the repository at this point in the history

Commits on Apr 2, 2023

  1. Fix implementations of isOpen and isEmpty

    @sleeplesslord
    sleeplesslord committed Apr 2, 2023
    Configuration menu
    Copy the full SHA
    a69185c View commit details
    Browse the repository at this point in the history

  2. Remove unnecessary subscription cancel

    @sleeplesslord
    sleeplesslord committed Apr 2, 2023
    Configuration menu
    Copy the full SHA
    bc960cd View commit details
    Browse the repository at this point in the history

  3. Handle future and downstream notification on cancel

    @sleeplesslord
    sleeplesslord committed Apr 2, 2023
    Configuration menu
    Copy the full SHA
    54a77e2 View commit details
    Browse the repository at this point in the history

  4. Rename variable to a more fitting name

    @sleeplesslord
    sleeplesslord committed Apr 2, 2023
    Configuration menu
    Copy the full SHA
    1cc7db7 View commit details
    Browse the repository at this point in the history

  5. Move check into event loop to remove volatile

    @sleeplesslord
    sleeplesslord committed Apr 2, 2023
    Configuration menu
    Copy the full SHA
    80cebda View commit details
    Browse the repository at this point in the history

Commits on Mar 21, 2024

  1. Merge branch 'main' into flatmap

    @jrhee17
    jrhee17 committed Mar 21, 2024
    Configuration menu
    Copy the full SHA
    8b2b98e View commit details
    Browse the repository at this point in the history

Commits on Mar 25, 2024

  1. handle leaks and concurrentmodificationexception

    @jrhee17
    jrhee17 committed Mar 25, 2024
    Configuration menu
    Copy the full SHA
    eeb2085 View commit details
    Browse the repository at this point in the history

Commits on Apr 1, 2024

  1. Return early and decrease the demand before calling onNext

    @minwoox
    minwoox committed Apr 1, 2024
    Configuration menu
    Copy the full SHA
    e7b3d7f View commit details
    Browse the repository at this point in the history

  2. Call completionFuture.completeExceptionally after subscriber.onError

    @minwoox
    minwoox committed Apr 1, 2024
    Configuration menu
    Copy the full SHA
    b7ac1c4 View commit details
    Browse the repository at this point in the history

Commits on Apr 9, 2024

  1. minor clean up

    @ikhoon
    ikhoon committed Apr 9, 2024
    Configuration menu
    Copy the full SHA
    3b35003 View commit details
    Browse the repository at this point in the history