mirror of
https://github.com/status-im/embark-area-51.git
synced 2025-01-10 05:56:00 +00:00
remove isListening action and just use the watch one
This commit is contained in:
parent
2f2a48bd41
commit
abe3aa4a80
@ -10,7 +10,6 @@ export const RECEIVE_PROCESSES_ERROR = 'RECEIVE_PROCESSES_ERROR';
|
||||
export const FETCH_PROCESS_LOGS = 'FETCH_PROCESS_LOGS';
|
||||
export const RECEIVE_PROCESS_LOGS = 'RECEIVE_PROCESS_LOGS';
|
||||
export const WATCH_NEW_PROCESS_LOGS = 'WATCH_NEW_PROCESS_LOGS';
|
||||
export const IS_LISTENING_PROCESS_LOG = 'IS_LISTENING_PROCESS_LOG';
|
||||
export const RECEIVE_NEW_PROCESS_LOG = 'RECEIVE_NEW_PROCESS_LOG';
|
||||
export const RECEIVE_PROCESS_LOGS_ERROR = 'RECEIVE_PROCESS_LOGS_ERROR';
|
||||
// Blocks
|
||||
|
@ -4,7 +4,7 @@ import {
|
||||
RECEIVE_PROCESS_LOGS,
|
||||
RECEIVE_PROCESS_LOGS_ERROR,
|
||||
RECEIVE_NEW_PROCESS_LOG,
|
||||
IS_LISTENING_PROCESS_LOG
|
||||
WATCH_NEW_PROCESS_LOGS
|
||||
} from "../actions";
|
||||
|
||||
export default function processes(state = {}, action) {
|
||||
@ -38,7 +38,7 @@ export default function processes(state = {}, action) {
|
||||
}
|
||||
};
|
||||
}
|
||||
case IS_LISTENING_PROCESS_LOG: {
|
||||
case WATCH_NEW_PROCESS_LOGS: {
|
||||
return {
|
||||
...state,
|
||||
data: {
|
||||
|
@ -94,7 +94,6 @@ export function *watchInitBlockHeader() {
|
||||
}
|
||||
|
||||
export function *listenToProcessLogs(action) {
|
||||
yield put({type: actions.IS_LISTENING_PROCESS_LOG, processName: action.processName});
|
||||
const socket = api.webSocketProcess(action.processName);
|
||||
const channel = yield call(createChannel, socket);
|
||||
while (true) {
|
||||
|
Loading…
x
Reference in New Issue
Block a user