Потому что его нету в OTP

Потому что его нету в OTP

хммм... отп спроектировали еще "при царе Горохе" ))) Еликсир-же волен себе в core и генстэйдж встроить. не?

Я думаю Жозе будет пытаться встроить его в OTP

С учётом того как он коммитит в Erlang - это реально

Я думаю Жозе будет пытаться встроить его в OTP

норм-же было бы! штука полезная!

Я запилил почти

То что хотел

На ген стейдж

Единственное пока не понял

Как пинать продюсер

Что значит пинать?

Там надо пинать консьюмер а не продьюсер

Но смысл в том, что как его пинать - тоже не понятно

Короче говоря, из того что я понял - ГенСтейдж это наебос. Тебе кажется что он решает твои проблемы - но он нихера не решает.

Просто связывает несколько процессов. Но вот как именно инициировать приём-передачу нужно делать самому

А это самое непонятное

И короче когда говорят что дискорд там что-то там уменьшил количество серваков - это значит что они не умеют нихера готовить ОТП

Геестейдж это такой копромисс между Enum/Stream.

Как я это понимаю

А Флоу можно сделать на генсерверах

genStage это попытка как-то двинуться в сторону того, что бы заявить о том, что elixir типа реактивен и соблюдает reactive manifesto

Нет, Флоу это компромисс

Короче я ещё почитал и запутался нафиг

хммм... прикрутил стэдж к моей задачке... не завелся ((( Где накуролесил? надо трэйсить... ((((

Я правильно понимаю, что после того как בםמדוצקר выполняет handle_events, он заново выпоняет handle_events?

И так по кругу до бесконечности?

Consumer*

Т.е. по сути такой циклический исполнитель. А если в продьюсере закончились, то он подвисает

хммм... у меня похожая нить рассуждений. есть подозрение, что ошибочное... Передымлю титульную стр. https://hexdocs.pm/gen_stage/GenStage.html

Так а когда тогда выполняются handle_info?

Или он после выполнения handle_events самому себе шлёт cast {:handle_events} и оно добавляется в очередь

Ладно, с консьюмером что-то понятно.

А вот продьюсер к примеру - хочу посылать запросы в друзья в вк. Проверяю через апи есть ли запросы - нету. И чё делать тогда?

Не выходить из handle_demand до тех пор пока не придёт запрос в друзья и в цикле долбить АПИ?

короч нихера не понятно.

А есть где-нибудь рубрика "спроси у Жозе"? я бы у него спросил...

наверняка он в слаке тусуется

Не выходить из handle_demand до тех пор пока не придёт запрос в друзья и в цикле долбить АПИ?

Нет.

https://elixirforum.com/t/my-genstage-producer-runs-out-of-work-to-do-i-buffer-demand-but-how-do-i-know-there-is-new-work/3437/3

https://elixirforum.com/t/genstage-and-twitter-stream/1435/12

А есть где-нибудь рубрика "спроси у Жозе"? я бы у него спросил...

На elixirforum.com можешь и спросить.

Ух ты, спасибо!

На самом деле, лучше поискать какой-нибудь враппер API, который использует GenStage.

Я короче всё-таки не понял. Если я прошу у продьюсера к примеру 10 сообщений, он стучит http и получает 9 - что тогда делать?

Посылать 9?

Вроде бы GenStage сам их посылает.

Но да, вернуть 9.

Там надо пинать консьюмер а не продьюсер

Ты не понял

И сохранить demand.

Так а кто вообще решает, чему равен demand?

Вроде как консьюмер работает в handle events с одним евентом только

Так а кто вообще решает, чему равен demand?

consumer

Или handle demand тоже все время запускается по кругу, просто если консьюмер тупит то туда в demand прилетают нули?

Вроде как консьюмер работает в handle events с одним евентом только

Туда лист приходит.

В доке блядь хуй че разберёшь

Три примера

И ебитесь

Как хотите

И Валим на конференции Тататрин

Вот у меня продюсер

В него пинаешь хуйню

А-ля sync

А есть где-нибудь рубрика "спроси у Жозе"? я бы у него спросил...

Жозе в IRC отвечает.

С датой

Он и дальше попер до консюмера

ERROR: S client not available

Там в консюмере сделал

Хуйню

И все

Вон пример с бродкастом глянь

Короче говоря, я правильно понял что handle demand крутится в цикле, и если в первый раз ты недодал, то во второй раз просто даёшь больше на столько, на сколько в первый раз недодал?

Использовал EventManager из статьи: https://pastebin.com/BeLfPx42 Лонгполлинг эвентов вкалтакта: https://pastebin.com/p0HXGSRJ

`sync_notify`в эвентменеджере.

Ну да

timeout можно выставить :infinity, ну и тогда поллер не отправит продюсеру эвенты, пока в этом не появится необходимость.

Там есть пример где он в лупе хуярит

С супервизором

Я так и сделал

По идее producer сам может (если не должен) быть поллером.

А есть где-нибудь рубрика "спроси у Жозе"? я бы у него спросил...

на форуме или на гитхабе (правда на гитхабе на меня наорали и отправили на форум)) )

Я просто пытаюсь понять кто вызывает handle events и handle demand

Это происходит behind the scenes.

Это блять меня осчастливит и решит все вопросы

Как хотите

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

Это происходит behind the scenes.

По идее тебе не нужно об этом беспокоиться, в общем.

По идее я могу работать с генсервером только потому что знаю как написать его самому

Сорцы посмотри.

Но вообще да, не хватает real world примеров.

Я смотрел - 4к лок и нихуя не понятно)

По идее я могу работать с генсервером только потому что знаю как написать его самому

Зачем?

Ты из лиги говнякиных?

Я ж не говорю что я его сам буду писать. Но я знаю как он работает от и до

Использовал EventManager из статьи: https://pastebin.com/BeLfPx42 Лонгполлинг эвентов вкалтакта: https://pastebin.com/p0HXGSRJ

В данном случае профит от использования GenStage довольно сомнительный, наверное.

Но это УДОБНО.

https://pastebin.com/vgXq0yaY

Вот примеру в комментах очень часто написано GenStage internal buffer. А что это?

Я смотрел - 4к лок и нихуя не понятно)

ставлю доллар на то что Максим Сохацкий скажет что это все - говно, и на самом деле это пишется в 100 loc Ы)