AO
кстати попутно еще вопрос , как пробросить аргумент из одной функции в другую ?
Size: a a a
2021 May 14
AO
он используется для одной функции
AO
к слову как я написал
(freeRes, xml)он не видет xml
RY
switchMap(result => obs1$.pipe(
switchMap(result2 => getObs2$(result1, result2).pipe(
switchMap(result3 => getObs3$(result2, result3)))
switchMap(result2 => getObs2$(result1, result2).pipe(
switchMap(result3 => getObs3$(result2, result3)))
AO
как я и изначально написал
RY
А, ну да
Можно еще так:
Можно еще так:
switchMap(result => obs1$.pipe(map(result2 => [result1, result2])),....
switchMap(([result1, result2]) => getObs2$(result1, result2)),
AF
Как правильно прописать здесь mergeMap, что бы срабатывали не все 30 элементов в массиве, а по 3 элемента.
Сейчас внутри mergeMap проходит один раз весь массив. Не правильно прописал аргумент concurrent?
Сейчас внутри mergeMap проходит один раз весь массив. Не правильно прописал аргумент concurrent?
АL
Переслано от Александр Laksan...
Добрый день. Подскажите пожалуйста...
У меня проблема, я не понимаю, как установить
У меня проблема, я не понимаю, как установить
timeline . "@ Swimlane / ngx-charts" обновил до версии "18.0.1". Подскажите пожалуйста, как отобразить timeline?. Ребята закрыли тикет https://github.com/swimlane/ngx-charts/pull/1593VM
форкДжоин сработает только когда все 30 элементов завершатся
VM
мб тебе больше подойдет combineLatest
VM
и возможно concurrent не будет работать с of. так как of сразу выполнится. можно delay добавить.
AF
from([1.2.3]).pipe(mergeMap(x => x)) - работает. но тут я сам должен следить за тем когда отработает последний раз mergeMap
AI
мб расскажи, чего хочешь добиться, а так:
merge($stream1.pipe(takeLast), $stream2.pipe(takeLast)).pipe(bufferCount(3)).subscribe()
merge($stream1.pipe(takeLast), $stream2.pipe(takeLast)).pipe(bufferCount(3)).subscribe()
АЖ
всем привет! у меня есть функция getAddres которое возвращает адреса и после него идет условие с циклом. Бывают моменты когда функция еще не завершилась а условие с циклом выполнились раньше, я пофиксил этот момент так:
of(this.getAddress(address, this.regions)).subscribe(() => {
условие
});
можете сказать правильно я сделал? Создал стрим из функций и в подписке добавил условие
of(this.getAddress(address, this.regions)).subscribe(() => {
условие
});
можете сказать правильно я сделал? Создал стрим из функций и в подписке добавил условие
AI
что внутри
this.getAddress? мб там что-то асинхронное?АЖ
address.forEach((a: Address) => {
const currentRegions: IEventLocations = regions.find((r: IEventLocations) => r.id === a.locationId);
if (currentRegions) {
currentRegions.address = a.addresses;
}
});
const currentRegions: IEventLocations = regions.find((r: IEventLocations) => r.id === a.locationId);
if (currentRegions) {
currentRegions.address = a.addresses;
}
});
AI
если код везде синхронный как могло получиться что “функция еще не завершилась а условие с циклом выполнились раньше”?
of().subscribe() - в данном случае ничего все равно не решает
of().subscribe() - в данном случае ничего все равно не решает
АЖ
тут я беру адреса и каждому региону добавляю ключь address и присваиваю. Но вопрос не в этом, создавать стрим из функции хорошая практика?
АЖ
нет, код асинхронный
AI
сходу не вижу асинк ничего…