много приходится велосипедить? на сколько это трудозатратно? может это настолько прикольно/кайфово, что пишешь и радуешься

драйверы нужные написать, и это легко

если с DOM то можно использовать готовые какие-то левые компоненты, например react

И значит пересчета только лишь одного компонента не получится

А на второй вопрос? Например, если по несколько раз в секунду у меня должно меняться показание какого-то счётчика. И я не хочу что б при при каждом кадре рендера анализировалось все огромное дерево компонентов приложения.

Оно и не анализируется, в snabbdom есть проверка на равенство

вот например extension для vscode на cycle

https://github.com/whitecolor/vscode-taskmate/blob/08ceed490bb57ed5c1b101ca978555a596312fb8/src/extension.ts

То есть если поддерево представляет собой тот же объект, что и раньше, оно пропускается

То есть если поддерево представляет собой тот же объект, что и раньше, оно пропускается

Прикольно! Интересно, а как это по бездействию в сравнении с connect от react-redux?

То есть если поддерево представляет собой тот же объект, что и раньше, оно пропускается

ты имеешь ввиду если distictUntiChanged?

Оно и не анализируется, в snabbdom есть проверка на равенство

хотя, там есть еще место для оптимизации

и лучше сразу готовиться писать на TypeScript если собираетесь использовать cycle

т.к. без типов долго не попишешь, более или мене сложнее что-то

ты имеешь ввиду если distictUntiChanged?

Или если combineLatest

Или если combineLatest

ну если combineLatest сработал, а итоговое значение не отлично от предыдущего (бывает еже) уйдет в sink, тут уже будет зависить как быстро snabbdom брабатывать будет

Оно полностью совпадает с предыдущим, когда обновление произошло в другом поддереве

Если у тебя C = A.combineLatest(B)

То когда B эмитит, значение из A не меняется

Снебдом видит это и не трогает поддерево A

может быть что при combine(A, B) -> C изменениях в A или B, C не будет меняться)

т.е. он де-факт не должен будет менять DOM, но в sink уйдет, не частая ситуация

Это не тот случай, о котором был вопрос

https://github.com/caiogondim/pipeline.js

https://github.com/caiogondim/pipeline.js

Нет передачи в виде списка-массива = не нужен

мне для такого пришлось писать свою обертку-пайплайн над ramda

унииверсальную, чтоб и так и так можно было передавать, в зависимости от ситуации

Нет передачи в виде списка-массива = не нужен

(...[a, b, c])?

Привет всем. Прошу минуту вашего внимания. Я хочу выступить на ReactiveConf и для этого мне нужно войти в тройку по количеству старов: https://gist.github.com/A-gambit/1ded6bf07cf4a497fc6eeb3e082ac612 Конкуренция очень велика и каждый стар имеет значение. Буду благодарен, если вы поможете мне в этом. Спасибо за внимание!

Друзья, давай поддержим Григория! У него 196 звёзд, а у его конкурентов 197 и 195. Каждый голос важен!

(...[a, b, c])?

Вся фишка в том, что это не известно заранее У тебя просто прилетает в пайп значение, если это массив, то делаешь rest, если нет, то отправляешь в пайп

Возможно у меня просто какой-то узкий кейс, но так удобней составлять алгоритм на лету, просто собирая нужный массив

В sanctuary pipe например с массивом работает

кто использует rxjs5, помогите плз разобраться с оператором bufferToggle

хоть убей не понимаю как работает

сейчас опишу задачу:

есть tracks$: Observable объектов, у которых есть .size, мне нужно накапливать их, пока совокупный размер буфера не достигнет размера N

собирает элементы между событиями двух потоков

нарисовано ве

да это я понимаю

openings, closings

я понял, это-то не сложно

ок, на реальном примере: let total = 0; const buffered$ = tracks$.bufferToggle(tracks$, track => { total += track.size; if (total > BUFFER_SIZE_BYTES) { total = 0; return // what? } return // what? });

bufferCount

мне нужен не count, а total size + можно ли тут обойтись без переменной total?

bufferWhen

а там ф-ция без аргументов, в bufferWhen, не оч понятно как условие задать если мне track не приходит

вообще window скорее тебе надо

оо

я забыл про window вообще

если я правильно понял задачу

да, сек, посмотрю, спасибо

но там не буфер а поток получается

или вообще обычный buffer нужно

в closingNotifier делаешь reduce(size)

tracks$.reduce((total, track) => total + track.size, 0) мне нужно получить Observable, который будет эмитить, когда totalSize превысит MAX_BUFFER_SIZE, он и будет переключателем для .buffer, такая идея? я новичок, если что в rxjs (%

можно как-то так сделать, а можно вообще просто с reduce

возращаешь из reduce {buffer, size}

когда буфер переваливает возвращаешь в size 0

пропускаешь накопленный только если size 0

супер, рабоатет

и если педыдущее значение содержит size 0 начинаешь собирает новый буфер

по разному можно сделать

спасибо) я сделал как выше написал

?

мб боян, но пока бесплатно https://egghead.io/courses/rxjs-subjects-and-multicasting-operators сам только собираюсь сейчас посмотреть

вроде ночью только выкатили. Андре недавно писал

посмотрел его, хороший, для начинающих как я – норм хотя многое быстро забывается, тк не используешь каждый день – слишком много всего в rxjs, даже с учетом выпиленного

факт

https://m.youtube.com/watch?v=R2FtMbb-nLs

Люди, не напомните оператор, который принимает несколько потоков, и срабатывает только если все они завершились?

Короче нужно прописать обработчик, который срабатывает когда завершились два ajax-запроса

combineLatest ?

Похоже на то

Ну или Promise.all =)

combineLatest ?

Спасибо огромное! Да, подходит! )

начал раскуривать rxjs и много чего не понял внутри

например, что значит PartialObserver с таким странным определением: export type PartialObserver<T> = NextObserver<T> | ErrorObserver<T> | CompletionObserver<T>; где все эти 3 типа одинаковые ?

или

это в Subscriber.ts: [$$rxSubscriber]() { return this; } потом используется вот так в toSubscriber: if (nextOrObserver[$$rxSubscriber]) { return nextOrObserver[$$rxSubscriber](); } с виду кажется бесмысслицей

пойду в гиттер поспрашиваю к ним зачем это все)

А зачем вам погружаться во внутренности, которые имеют тенденцию меняться? Почему вам не достаточно просто знать API?

Вы хотите написать свой rxjs? Или просто таким образом осваиваете javascript?