31 lines
665 B
JavaScript
31 lines
665 B
JavaScript
|
import { put, take, race, fork } from 'redux-saga/effects';
|
||
|
|
import { delay } from 'redux-saga';
|
||
|
|
import * as types from '../actions/actionsTypes';
|
||
|
|
|
||
|
|
import { setActiveUser } from '../actions/activeUsers';
|
||
|
|
|
||
|
|
const watchActiveUsers = function* handleInput() {
|
||
|
|
let obj = {};
|
||
|
|
while (true) {
|
||
|
|
const { status, timeout } = yield race({
|
||
|
|
status: take(types.ACTIVE_USERS.REQUEST),
|
||
|
|
timeout: delay(3000)
|
||
|
|
});
|
||
|
|
if (timeout && Object.keys(obj).length > 0) {
|
||
|
|
yield put(setActiveUser(obj));
|
||
|
|
obj = {};
|
||
|
|
}
|
||
|
|
if (status) {
|
||
|
|
obj = {
|
||
|
|
...obj,
|
||
|
|
...status.user
|
||
|
|
};
|
||
|
|
}
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
const root = function* root() {
|
||
|
|
yield fork(watchActiveUsers);
|
||
|
|
};
|
||
|
|
export default root;
|