DG
Size: a a a
2018 November 06
IF
мм Ланет)
DG
rxjs
m
вот это ближе всего
m
Arsenii Tverdokhleb
Мб тебе надо шото типа:
const aBtn = document.getElementById('aBtn');
const bBtn = document.getElementById('bBtn');
const cBtn = document.getElementById('cBtn');
const aBtn$ = Rx.Observable.fromEvent(aBtn, 'click');
const bBtn$ = Rx.Observable.fromEvent(bBtn, 'click');
const cBtn$ = Rx.Observable.fromEvent(cBtn, 'click');
Rx.Observable.merge(
aBtn$.map(() => 1),
bBtn$.map(() => 2),
cBtn$.map(() => 3)
)
.flatMapLatest(data => Rx.Observable.interval(100).map(() => data))
.subscribe(data => console.log(data));
const aBtn = document.getElementById('aBtn');
const bBtn = document.getElementById('bBtn');
const cBtn = document.getElementById('cBtn');
const aBtn$ = Rx.Observable.fromEvent(aBtn, 'click');
const bBtn$ = Rx.Observable.fromEvent(bBtn, 'click');
const cBtn$ = Rx.Observable.fromEvent(cBtn, 'click');
Rx.Observable.merge(
aBtn$.map(() => 1),
bBtn$.map(() => 2),
cBtn$.map(() => 3)
)
.flatMapLatest(data => Rx.Observable.interval(100).map(() => data))
.subscribe(data => console.log(data));
Спасибо, это ближе всего к тому что я хотел сделать... А можно так сделать чтоб изначально была подписка на поток скажем of([]) и при инициализации сабскрайб выполнился.. и каждый раз когда сам поток выполняется срабатывал сабскрайб... + то что вы реализовали - если было нажатие на кнопку то выполнялась функция привязанная к кнопке получая данные из главного потока... ?
m
не.. я делаю подписку на поток... т.е данные там уже будут.. т.е мне не нужно специально задавать startWith.. это только для репродюса...
DG
поток потоку рознь, нужно уточнять
DG
вам никто не мешает делать с потоками любые преобразования, прежде чем объединять их с другими потоками. постарайтесь доступно объяснить, что вы хотите сделать и вам помогут
2018 November 07
m
поток потоку рознь, нужно уточнять
по хорошему startWith([]).. сделает почти тоже.. что и of([]) ... это мой основной поток.. нужно чтоб потоки на кнопках брали значение текущее и могли с ним как то работать.. в этом идея...
DG
of создаст поток, а startWith будет эмитировать значение в уже существующий. по-моему это вообще не одно и то же
DG
до сих пор не понятно, что вы хотите сделать
m
of создаст поток, а startWith будет эмитировать значение в уже существующий. по-моему это вообще не одно и то же
возможно вы правы на счет этого... не знал этого ньюанса
m
Итоговая версия, если кому интересно - https://jsbin.com/pawerumoxo/1/edit?js,console,output
Огромное спасибо @hitpopdimestop за помощь! 🍺🍺
Огромное спасибо @hitpopdimestop за помощь! 🍺🍺
O
привет, подскадите, планируется очередной митап?
L
Пока не планируется😔
AO
планируется. но вот когда? 🙂