before channels

before-channels.js

import * as effects from "redux-saga/effects";
import * as constants from "../actions/constants";

function* processTaskTimeConsuming() {
  yield effects.delay(1000 + 1000 * Math.random());
  return true;
}

function* doProcessTask(name) {
  try {
    yield effects.put({ type: constants.TASK_PROCESS_START, name });
    yield effects.call(processTaskTimeConsuming);
    yield effects.put({ type: constants.TASK_PROCESS_DONE, name });
  } catch (error) {
    yield effects.put({ type: constants.TASK_PROCESS_ERROR, name });
  } finally {
    if (yield effects.cancelled()) {
      yield effects.put({ type: constants.TASK_PROCESS_RESET, name });
    }
    return true;
  }
}

function* processTask(action) {
  yield effects.call(doProcessTask, action.name);
}

export function* rootSaga() {
  while (true) {
    const action = yield effects.take(constants.TASK_PROCESS);
    yield effects.call(doProcessTask, action.name);
  }
}