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

MQTT streaming: SourceQueue backpressure #1577

Merged
merged 6 commits into from
Jul 1, 2019
Merged

MQTT streaming: SourceQueue backpressure #1577

merged 6 commits into from
Jul 1, 2019

Commits on Jul 1, 2019

  1. mqtt streaming - introduce a mechanism to use SourceQueue backpressure 

    When offering commands to the internal queue, a backpressure strategy is
now used to ensure that elements are not dropped. Instead, we wait for
consumption downstream before continuing.
    @longshorej @2m
    longshorej authored and 2m committed Jul 1, 2019
    Configuration menu
    Copy the full SHA
    e445205 View commit details
    Browse the repository at this point in the history

  2. Harden test 

    I noticed that a test wasn’t quite right - the client should only complete after we’ve received all elements. We now use “take” to ensure that the stream completes.
    @huntc @2m
    huntc authored and 2m committed Jul 1, 2019
    Configuration menu
    Copy the full SHA
    c7a0ed2 View commit details
    Browse the repository at this point in the history

  3. Don’t let WatchedActorTerminatedException fail the session streams 

    We want WatchedActorTerminatedException to complete stream processing as before, but not with a failure. A session shutting down isn’t in itself a failure.
    @huntc @2m
    huntc authored and 2m committed Jul 1, 2019
    Configuration menu
    Copy the full SHA
    a925fe2 View commit details
    Browse the repository at this point in the history

  4. Mima exclude; improve toString

    @ennru @2m
    ennru authored and 2m committed Jul 1, 2019
    Configuration menu
    Copy the full SHA
    930046b View commit details
    Browse the repository at this point in the history

  5. Scalafmt

    @ennru @2m
    ennru authored and 2m committed Jul 1, 2019
    Configuration menu
    Copy the full SHA
    3d9c2aa View commit details
    Browse the repository at this point in the history

  6. Rename MiMa excludes file to the latest released version

    @2m
    2m committed Jul 1, 2019
    Configuration menu
    Copy the full SHA
    e096ddb View commit details
    Browse the repository at this point in the history