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 local error consumer hooks support #830

Merged
merged 5 commits into from
Sep 5, 2017
Merged

Add local error consumer hooks support #830

merged 5 commits into from
Sep 5, 2017

Commits on Sep 4, 2017

  1. Contextualize Operators.onErrorDropped and onNextDropped 

    - remove unused Operators.onErrorDropped(error, supp)
- add few missing Operators.onNextDropped
    @simonbasle
    Stephane Maldini authored and simonbasle committed Sep 4, 2017
    Configuration menu
    Copy the full SHA
    e0b04b4 View commit details
    Browse the repository at this point in the history

  2. Contextualize Operators.onOperatorError and onRejectedExecution 

    - fix UnicastProcessor currentContext
    @simonbasle
    Stephane Maldini authored and simonbasle committed Sep 4, 2017
    Configuration menu
    Copy the full SHA
    9831c5a View commit details
    Browse the repository at this point in the history

  3. remaining calls to drops without a context either use explicit empty... 

    or are "multicast" cases mark as such for future refactor
    @simonbasle
    simonbasle committed Sep 4, 2017
    Configuration menu
    Copy the full SHA
    b1237b8 View commit details
    Browse the repository at this point in the history

  4. look for local hooks in Context for onErrorDropped/onNextDropped/onOp… 

    …eratorError/onRejectedExecution
    @simonbasle
    simonbasle committed Sep 4, 2017
    Configuration menu
    Copy the full SHA
    df21ff9 View commit details
    Browse the repository at this point in the history

Commits on Sep 5, 2017

  1. ability to local hook for Operators.onRejectedExecution 

    this works by replacing the onOperatorError hook in the context passed
when calling Operators.onOperatorError from onRejectedExecution (if
there is a local hook for the REE-specific key).
    @simonbasle
    simonbasle committed Sep 5, 2017
    Configuration menu
    Copy the full SHA
    25aef6c View commit details
    Browse the repository at this point in the history