YK
на 10:55 - „а вообще было бы удобно, чтобы метод subscribe вызывался столько раз, сколько есть ответов, для того чтобы мы всегда работали с отдельным пользователем“
Size: a a a
2020 February 04
YK
мне вот вообще не очевидно, что в этом удобного
Вキ
мне вот вообще не очевидно, что в этом удобного
Это можно использовать, чтобы обработать сообщения по отдельности, а потом (если требуется) снова объединить воедино
YK
ну, то есть, если надо, например, для каждого юзера запросить какую-то доп. информацию с сервера
Вキ
ага, что-то типа такого
YK
но если надо просто массив отмапить - лучше ж просто его отмапить?
G
ну как у него получилось то из массива сделать поток? ))
OS
ну как у него получилось то из массива сделать поток? ))
у него не из массива а из fromEvent поток идёт
Вキ
ну как у него получилось то из массива сделать поток? ))
mergeMap, как и многие другие операторы, принимают ObservableInput
type ObservableInput<T> = SubscribableOrPromise<T> | ArrayLike<T> | Iterable<T>;
https://rxjs-dev.firebaseapp.com/api/index/type-alias/ObservableInput
type ObservableInput<T> = SubscribableOrPromise<T> | ArrayLike<T> | Iterable<T>;
https://rxjs-dev.firebaseapp.com/api/index/type-alias/ObservableInput
OS
ну как у него получилось то из массива сделать поток? ))
чем не устраивает
обработка каждого элемента подразумевает какие то запросы или сложные вычисления?
Даже не так а
of(arrayFromServer).pipe(map(#TODO#))как уже выше предлагалось?
обработка каждого элемента подразумевает какие то запросы или сложные вычисления?
Даже не так а
return http.post(url).pipe(map(#todo#))
YK
ну как у него получилось то из массива сделать поток? ))
of
G
нет просто формирование нового массвиа с элеменами нужного типа
YK
нет просто формирование нового массвиа с элеменами нужного типа
тогда просто array мап в rx мапе!
OS
нет просто формирование нового массвиа с элеменами нужного типа
ну так верните из сервиса Observable, а в сервисе не подписывайтесь а просто верните запрос с доп pipe
getItems(): Observable<myItem[]> {
return this.http(url).pipe(map(array => array.map(тут логика));
}OS
тогда просто array мап в rx мапе!
++
YK
зачем расхреначивать массив на обзервабл, если потом у вас просто преобразование одного вида объектов в другой вид объектов, без никакой асинхронности
OS
нет просто формирование нового массвиа с элеменами нужного типа
в зависимости от задачи маппинг мб лучше вынести в компонент, а не в сервисе реализовывать
OS
зачем расхреначивать массив на обзервабл, если потом у вас просто преобразование одного вида объектов в другой вид объектов, без никакой асинхронности
я слышал, что чем больше observable в твоём коде, тем ты более крутой разраб:)
YK
я слышал, что чем больше observable в твоём коде, тем ты более крутой разраб:)
ну ты видел, я сверху (вчера ночью тема) тоже старался соответствовать))