тьфу сорри за отступы

наговнокодил и бросил

да не

увидел различие отступов

слил их до нуля

и проглядел чтео

выпилю-ка

А где очищение? О_о

let'ы вместо const'ов, var'ы

Ой, да идите вы со своими const

Будь это про иммутабельность, было бы ок

а так это хз вообще зачем такое

Это иммутабельность значения

Примитива/ссылки

Сделай паузу стрима на время операции.

Это корявенько

Скрин пропал, но вроде там не в коллбеке обновление было

Но это ладно. Так-то да, проблема именно в том, что не ожидаешь

Либо явнную паузу, либо readable + read()

Но лучшее решение: сделай writeable стрим

в монгу?

ну да

как обновилось — вызвал cb()

ну бафер то все равно будет забит без паузы

Тут должно быть так: readable -> transform -> writable

Да, но буфер ограничен по дефолту

И как только заполняется, то делается пауза

Она же даелтся на уровне я перестаю читать из канала чтения

иначе если продолжить писать во врайт бафер врайт стрима все еще будет переполнен

Не понял

У writeable и у readable есть собственные буферы

16 кб по дефолту

я правильно понял про паузу стрима на время массовой заливки в монгу?

и что ты с ними сделаешь что бы писать в монгу объекты? только абстракцию какую-то или разбор в те же объекты читая из канала вообщем далеко не уйдешь .

Ну да нужна пауза

Дык, ты в _write дёргаешь cb, когда готов дальше принимать данные

и непонятная история что у тебя за стрим es.split

а дёргаешь ты его когда mongo записала данные

они у тебя все еще в буфере хранятся в том который 16кб по дефолту если больше 16 дропать его?

нет, pause будет, если больше

ну вот получается что все к той же паузе

да, только идеоматично

и это только создало дополнительный слой абстракции для одноразовой задачи лол

Ну ты почитай https://nodejs.org/api/stream.html , там хорошие примеры даны как это делается идеоматично соверменной ноде на стримах

readable -> tranform -> writeable это практически классика

es.split чтобы файл читать построчно

Yan, не ясно какой смысл от тех пауз что ты поставил

update же асинхронный

ну и вполняется он в момент когда ты execute вызываешь

это же bulk

ты копишь их в клиенте

ну да-да, я не так выразился

имел ввиду что толк-то есть от pause этого?

нужно постпавить перед execute тогда и внутри него resume

да

Или сделать на потоках, как и надо

@vkurchatkin, а у флоу есть тайпинги для ноды изкаропки? А то у меня на Buffer.from ругалось на работке.

в смысле сдлеать на потоках?

это?

readable -> tranform -> writeable это практически классика

да

прочитать строку а точнее 3к и перед bulk.execute трансформировать во writetable?

нет, смотри

возьми водку

ERROR: S client not available

и стакан

это важный элемент аналогии

они при мне

readable твой это из файла стандартный. Transform просто получает на вход поток, бьёт его по строкам и выдаёт дальше в objectMode данные для ставки. writeable тупо принимает данные и пока их меньше чем заданные порог (3000), добавляет в bulk, как только стало 3000 — делаешь execute и вызываешь callback

проще говоря сделай свой стрим который на _write будет дропать на монгу шит из бафера

и дрейнить на исполнение

. всё ок, принимает writeableObjectMode

ладно, всем бб

бб спасибо! попробу ща сделать

@vkurchatkin, а у флоу есть тайпинги для ноды изкаропки? А то у меня на Buffer.from ругалось на работке.

/cc @chicoxyzzy

есть, но не во всем полные

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

Оке, пасиб

кто нить поделитесь css'ом от github может кому на кэше остался)

Поставь оперу, тот же хром, только со встроенной банерорезкой и VPN

На мегафоне кстати нормально гитхаб работает

даже в сша не так работает

https://whoer.net/webproxy

УМВР

чуваки, Владимир Курчаткин самый крутой в этом чате. слушайте его всегда

кроме сообщений когда он говорит что флоу круче тс

хотя и тогда тоже

флоу — круто

:0

я прочитал херову срань сообщений и вот

так флоу круче тс? или флоу - круто, а тс еще круче?

тс круче

флоу - охуенно

все будет в тс

но не суть