MK
Попытался такое создать, но дебаунс не работает, его как будто проглатывает
Size: a a a
2021 April 27
AV
А возвращать обзервабл из строки, а не саму строку?
AV
Ну или если очень хочется, то проверять возвращаемый объект на предмет типа
BB
Сама суть того что метод возвращает разные типы данных уже плохо, ладно примитивы еще или у нмх какой-то общий интерфейс у них есть
Создавайте новый обсервабл со строкой
Создавайте новый обсервабл со строкой
D
Потому что of возвращаешь
MK
ну это если новый поток надо создать
D
А по потоку на чат почему не сделать? Так логичнее же
MK
я тестирую с одним чатом и все равно не хочет, то есть он один раз через оф создал и дальше уже только его использует
MK
ну так я же и создаю по потоку на чат
AR
Обзервабл из строки?
AR
Преобразовать строку в обзервабл?
AR
А как)
MK
а я понял про что ты имел ввиду, типо сам же of не проицирует данные
AR
Ах ну да) спасибо
D
Как то странно.
var socketStream$ = getStreamFromServer();
var chat1Stream$ = socketStream$.pipe(
filter (chatId => chatId === 1),
debounceTime(500)
);
var chat2Stream$ = socketStream$.pipe(
filter (chatId => chatId === 2),
debounceTime(500)
);
var socketStream$ = getStreamFromServer();
var chat1Stream$ = socketStream$.pipe(
filter (chatId => chatId === 1),
debounceTime(500)
);
var chat2Stream$ = socketStream$.pipe(
filter (chatId => chatId === 2),
debounceTime(500)
);
D
в socketStream события с сервера короче одним потоком все
MK
ну мне же динамически их нужно создавать