Streamingly reducers will now call on_error callback in the accumulator class if it's defined in event of exception