Advertisement
Guest User

Untitled

a guest
Oct 22nd, 2018
78
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Dart 0.67 KB | None | 0 0
  1. Observable<dynamic> _simulationStartEpic(
  2.     Stream<dynamic> actions, EpicStore<AppState> epicStore) {
  3.   return Observable(actions)
  4.       .ofType(TypeToken<SimulationStateChangedAction>())
  5.       .doOnData((action) {
  6.     _simulationStateSubject.add(action.simulationState);
  7.   }).switchMap((SimulationStateChangedAction action) {
  8.     if (action.simulationState == SimulationState.ENABLED) {
  9.       return _debouncedSummary()
  10.           .takeUntil(_simulationStateSubject.takeWhile(
  11.               (currentState) => currentState == SimulationState.DISABLED))
  12.           .map((summary) => AddEntryAction(summary));
  13.     } else {
  14.       return Observable.empty();
  15.     }
  16.   });
  17. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement