Как отменить наблюдаемое из другого процесса - PullRequest
Новая
       5

Как отменить наблюдаемое из другого процесса

0 голосов
/ 18 июня 2020

Предположим, у вас есть пакетное задание, выполняющееся в процессе. В качестве реализации вы используете наблюдаемые объекты.

Теперь вы хотите представить клиенту API. Таким образом, пользователь может отменить / остановить это запущенное пакетное задание. Запрос API будет в другом процессе, который будет обрабатываться вашим веб-сервером.

Я подумываю установить флаг в базе данных, который может установить API, и впоследствии процесс пакетного задания сможет читать, чтобы передать сигнал отмены. Может ли процесс пакетного задания периодически проверять, установлен ли этот сигнал? 

  const ob = from([1,2,3]);
  ob.pipe(mergeMap(i => {
    // do something
    return of(i);
  }, undefined, 1);

Может быть, это делает второй параметр mergeMap?

...