Add error handling

In the near future these will be handled by a toast.
This commit is contained in:
Berkeley Martinez
2016-01-05 12:34:50 -08:00
parent 0166f7da15
commit 7cb835aac4
3 changed files with 19 additions and 16 deletions

View File

@ -53,6 +53,12 @@ app$({ history, location: appLocation })
.doOnNext(title => document.title = title) .doOnNext(title => document.title = title)
.subscribe(() => {}); .subscribe(() => {});
appStore$
.pluck('err')
.filter(err => !!err)
.distinctUntilChanged()
.subscribe(err => console.error(err));
synchroniseHistory( synchroniseHistory(
history, history,
updateLocation, updateLocation,

View File

@ -80,9 +80,9 @@ export default Actions({
} }
}; };
}) })
.catch(err => { .catch(err => Observable.just({
console.error(err); transform(state) { return { ...state, err }; }
}); }));
}, },
toggleQuestions() { toggleQuestions() {
@ -243,13 +243,8 @@ export default Actions({
}) })
.delay(300) .delay(300)
.startWith(correctAnswer) .startWith(correctAnswer)
.catch(err => { .catch(err => Observable.just({
console.error(err); transform(state) { return { ...state, err }; }
return Observable.just({ }));
set: {
error: err
}
});
});
} }
}); });

View File

@ -1,5 +1,7 @@
import { Actions } from 'thundercats'; import { Actions } from 'thundercats';
import store from 'store'; import store from 'store';
import { Observable } from 'rx';
import { nameSpacedTransformer } from '../../../../utils'; import { nameSpacedTransformer } from '../../../../utils';
const assign = Object.assign; const assign = Object.assign;
@ -50,7 +52,7 @@ export default Actions({
}; };
} }
})) }))
.catch(err => ({ .catch(err => Observable.just({
transform(state) { transform(state) {
return { ...state, err }; return { ...state, err };
} }
@ -63,7 +65,7 @@ export default Actions({
return { ...state, currentJob: job }; return { ...state, currentJob: job };
}) })
})) }))
.catch(err => ({ .catch(err => Observable.just({
transform(state) { transform(state) {
return { ...state, err }; return { ...state, err };
} }
@ -76,9 +78,9 @@ export default Actions({
return { ...state, jobs }; return { ...state, jobs };
}) })
})) }))
.catch(err => ({ .catch(err => Observable.just({
transform(state) { transform(state) {
return { state, err }; return { ...state, err };
} }
})); }));
}, },
@ -161,7 +163,7 @@ export default Actions({
})) }))
}; };
}) })
.catch(err => ({ .catch(err => Observable.just({
transform(state) { transform(state) {
return { ...state, err }; return { ...state, err };
} }