diff options
Diffstat (limited to 'frontend/src/containers/App/saga.js')
-rw-r--r-- | frontend/src/containers/App/saga.js | 28 |
1 files changed, 0 insertions, 28 deletions
diff --git a/frontend/src/containers/App/saga.js b/frontend/src/containers/App/saga.js deleted file mode 100644 index 0c212142..00000000 --- a/frontend/src/containers/App/saga.js +++ /dev/null @@ -1,28 +0,0 @@ -import { put, take } from 'redux-saga/effects' -import { eventChannel } from 'redux-saga' - -function createSocketChannel(socket) { - return eventChannel(emit => { - const errorHandler = event => emit(JSON.parse(event.body)) - - const userErrors = socket.subscribe('/user/queue/errors', errorHandler) - - const unsubscribe = () => { - userErrors.unsubscribe() - } - - return unsubscribe - }) -} - -export function* watchOnErrors(socketConnection) { - const { socket } = socketConnection - const socketChannel = createSocketChannel(socket) - - while (true) { - const payload = yield take(socketChannel) - yield put({ type: 'USER_ERROR', payload }) - } -} - -export default watchOnErrors |