П
Мне кажется это не тот. Судя по ошибку у тебя где-то вызов xxx.job
Size: a a a
2020 February 14
OS
Вот так
может стоит где нибудь на stakblitz воспроизвести попробовать?
DB
Мне кажется это не тот. Судя по ошибку у тебя где-то вызов xxx.job
Да, это как раз что на инпут идёт. Сейчас tap(console.log) сделаю на источник
OS
товарищи, кто может подсказать.
Можно ли как то отложить выполнение observable до того, как другой observable выкинет значение.
Т.е. у меня есть поток событий, и, в случае, если пользователь не аутентифицирован, мне нужно их заблокировать, пока пользователь не введёт логин\пароль, а потом продолжить их посылать.
Можно ли как то отложить выполнение observable до того, как другой observable выкинет значение.
Т.е. у меня есть поток событий, и, в случае, если пользователь не аутентифицирован, мне нужно их заблокировать, пока пользователь не введёт логин\пароль, а потом продолжить их посылать.
DB
может стоит где нибудь на stakblitz воспроизвести попробовать?
Это слишком сложно будет) Я докопался до корня проблемы, кажется.
Вот так выглядит шаблон родителя (вся суть в первых 4-х строках)
Вот так выглядит шаблон родителя (вся суть в первых 4-х строках)
OS
Это слишком сложно будет) Я докопался до корня проблемы, кажется.
Вот так выглядит шаблон родителя (вся суть в первых 4-х строках)
Вот так выглядит шаблон родителя (вся суть в первых 4-х строках)
Похоже на то
DB
товарищи, кто может подсказать.
Можно ли как то отложить выполнение observable до того, как другой observable выкинет значение.
Т.е. у меня есть поток событий, и, в случае, если пользователь не аутентифицирован, мне нужно их заблокировать, пока пользователь не введёт логин\пароль, а потом продолжить их посылать.
Можно ли как то отложить выполнение observable до того, как другой observable выкинет значение.
Т.е. у меня есть поток событий, и, в случае, если пользователь не аутентифицирован, мне нужно их заблокировать, пока пользователь не введёт логин\пароль, а потом продолжить их посылать.
Это обычный условный switchMap,
auth$.pipe(switchMap(isAuth => isAuth ? stream : EMPTY))
auth$.pipe(switchMap(isAuth => isAuth ? stream : EMPTY))
OS
Это слишком сложно будет) Я докопался до корня проблемы, кажется.
Вот так выглядит шаблон родителя (вся суть в первых 4-х строках)
Вот так выглядит шаблон родителя (вся суть в первых 4-х строках)
16-21 строки выглядят подозрительно
DB
16-21 строки выглядят подозрительно
С ними точно всё в порядке)
OS
С ними точно всё в порядке)
я имею в виду может их в pipe убрать или в компонент куда нибудь.)
OS
Это обычный условный switchMap,
auth$.pipe(switchMap(isAuth => isAuth ? stream : EMPTY))
auth$.pipe(switchMap(isAuth => isAuth ? stream : EMPTY))
если у меня возникнет событие до того как пользователь вошёл в систему, оно у меня потеряется. Мне хотелось бы его просто заморозить до логина а потом продолжить, не бросая заново.
Звучит конечно так себе)
Звучит конечно так себе)
П
Это слишком сложно будет) Я докопался до корня проблемы, кажется.
Вот так выглядит шаблон родителя (вся суть в первых 4-х строках)
Вот так выглядит шаблон родителя (вся суть в первых 4-х строках)
Оно
Async оправдан 🔨
Async оправдан 🔨
П
В который раз 😆
DB
я имею в виду может их в pipe убрать или в компонент куда нибудь.)
Да я думаю над этим, пока не придумал как) С другими вещами разбирался.
Я тут на поток запрыгнул, вот такая картина
То есть сначала идёт попытка обращения к null, и только потом поток эмитит события
Я тут на поток запрыгнул, вот такая картина
То есть сначала идёт попытка обращения к null, и только потом поток эмитит события
DB
По идее попытка обращения к тому, что там сейчас null, должна быть только после того, как какое-нибудь события заэмитится
DB
если у меня возникнет событие до того как пользователь вошёл в систему, оно у меня потеряется. Мне хотелось бы его просто заморозить до логина а потом продолжить, не бросая заново.
Звучит конечно так себе)
Звучит конечно так себе)
А, ну тогда это bufferWhen 🙂
https://www.learnrxjs.io/learn-rxjs/operators/transformation/bufferwhen
https://www.learnrxjs.io/learn-rxjs/operators/transformation/bufferwhen
OS
А, ну тогда это bufferWhen 🙂
https://www.learnrxjs.io/learn-rxjs/operators/transformation/bufferwhen
https://www.learnrxjs.io/learn-rxjs/operators/transformation/bufferwhen
ооо, огонь, спасибо, в натуре чётко :D
DB
А, ну тогда это bufferWhen 🙂
https://www.learnrxjs.io/learn-rxjs/operators/transformation/bufferwhen
https://www.learnrxjs.io/learn-rxjs/operators/transformation/bufferwhen
Ну или что-нибудь из серии бафферов, там под задачу либо buffer, либо bufferWhen, либо bufferToggle
OS
Ну или что-нибудь из серии бафферов, там под задачу либо buffer, либо bufferWhen, либо bufferToggle
да, сейчас посмотрю, что там есть 👍
DB
Оно
Async оправдан 🔨
Async оправдан 🔨
А есть понимание, как может происходить такое, что обращение к async переменной происходит до того, как заэмитилось первое значение?