Всем привет. Возникла следующая задача: сделать бесконечный асинхронный цикл с таймаутом, который запрашивает данные с сервера. Особенность всего этого веселья в том, что требуется делать запросы пока стор не null и таймер требуется перезапускать при изменении данных в сторе. На rxjs (redux observable) все это добро выражается лаконично:

const makeColorsEpic = (action$: Observable<ReturnType<typeof successLoad>>) =>
  action$.pipe(
    ofType(succesLoad.type),
    switchMap(action => timer(0, 1000).pipe(
      map(() => makeColors(action.payload.nodes)),
      map(successColors),
      takeUntil(action$.pipe(
        ofType(clear.type)
      ))
    ))
  );

Как сделать так-же элегантно на effector?

Конечно) Но было бы классно именно создавать производный эффект с мапнутым done аналогично attach

в attch такое добавлять не совсем правильно: получится какой-то монстр, который и prepend делает для эффекта, и результаты мапает, и ещё со сторов данные может получать... название уже не будет соответсвовать сути

в attach да, это перегрузит его, но отдельный хелпер можно было бы сделать

Всем привет!
Есть такой кейс. Аттач позволяет аттачить данные к параметрам эффекта.
А что если мне хочется приаттачить данные к result эффекта.
Кейс родился по причине кривизны бэкенда. У меня чтобы получать приватные ассеты нужно jwt токен передавать в параметре запроса

Что то вроде того:

attachResult({
     source: $jwtToken,
     effect: getUserPhotoFx,
     mapResult: (photos, token) => photos.map((photo) => ({
             ...photo, src: addQueryParameter(photo.src, token) 
     }))
})

Я понимаю, что я могу мапнуть done ниже, или даже сэмплануть при передачи в on, но хотелось бы получить эффект модифицированный, так как это было бы очень удобно делать на уровне api

Возможно, это можно как то сделать уже сейчас? Обсуждался ли такой кейс?
По идее необходимость мапать ответ апи может появиться и по другим причинам

Всем привет!
Есть такой кейс. Аттач позволяет аттачить данные к параметрам эффекта.
А что если мне хочется приаттачить данные к result эффекта.
Кейс родился по причине кривизны бэкенда. У меня чтобы получать приватные ассеты нужно jwt токен передавать в параметре запроса

Что то вроде того:

attachResult({
     source: $jwtToken,
     effect: getUserPhotoFx,
     mapResult: (photos, token) => photos.map((photo) => ({
             ...photo, src: addQueryParameter(photo.src, token) 
     }))
})

Я понимаю, что я могу мапнуть done ниже, или даже сэмплануть при передачи в on, но хотелось бы получить эффект модифицированный, так как это было бы очень удобно делать на уровне api

Возможно, это можно как то сделать уже сейчас? Обсуждался ли такой кейс?
По идее необходимость мапать ответ апи может появиться и по другим причинам

в attach да, это перегрузит его, но отдельный хелпер можно было бы сделать

в repl воспроизводиться ?

Всем привет!
Есть такой кейс. Аттач позволяет аттачить данные к параметрам эффекта.
А что если мне хочется приаттачить данные к result эффекта.
Кейс родился по причине кривизны бэкенда. У меня чтобы получать приватные ассеты нужно jwt токен передавать в параметре запроса

Что то вроде того:

attachResult({
     source: $jwtToken,
     effect: getUserPhotoFx,
     mapResult: (photos, token) => photos.map((photo) => ({
             ...photo, src: addQueryParameter(photo.src, token) 
     }))
})

Я понимаю, что я могу мапнуть done ниже, или даже сэмплануть при передачи в on, но хотелось бы получить эффект модифицированный, так как это было бы очень удобно делать на уровне api

Возможно, это можно как то сделать уже сейчас? Обсуждался ли такой кейс?
По идее необходимость мапать ответ апи может появиться и по другим причинам

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

function createTimer(after: Event<any>, until: Event<any>, ms: number) {
  const event = createEvent();
  let timer: ReturnType<typeof setInterval> | null = null;
  after.watch(() => {
    event();
    if (timer) {
      clearInterval(timer);
    }
    timer = setInterval(() => event(), ms);
  });

  until.watch(() => {
    if (timer) {
      clearInterval(timer);
      timer = null;
    }
  });

  return event;
}

И переписать на эффекты

можно, только зачем?