Те сделать собственный протокол на upgrade в плаге мучение?

да, все классно если б Y отвечал синхронно. Но к меня Y асинхронная система. В ответе я только ref получу и все. Конец не получается.

Потом Y делает callback запрос в мое приложение. Так вот как callback от Y пробросить в процесс-запрашиватель в Elixir грамотно?

В erlang у меня ETS справочник хранит ref запроса и PID. При callback запросе из Y я беру ref и ищу в ETS нужный PID. и вот тогда конец

 А в Elixir как это сделать? опять городить ets + do ...receive и Process.send? Думаю никто так не делает....

Есть прекрасный Registry
Твой процесс запрашиватель совершает запрос и регистрируется в Registry под именем {:requester, request_reference}
Потом когда приходит ответ, плаговский процесс делает запрос на GenServer.cast({:via, Registry, {:requester, request_reference}}, reply_info)
И потом процесс запрашиватель отвечает на call и делает unregister из Registry

А самое прикольно то, что потом, если захочется сделать это распределённым, можно лёгким движением руки заменить дефолтный Registry на Horde и всё будет классно работать

Я понятно объяснил?

send + receive заменяется на call в 99% случаев

Не просто мучение, а вообще невозможно by design. Либо патч на plug, либо голый ковбой.

Нет в плаге апгрейдов

собственно, поэтому как раз в фениксе вместо вебсокетов каналы, и те реализованы невероятно через жопу

почитаю про Registry. спасибо.

Минусы эликсира подьехали?

Можно еще noreply/reply gen_server сделать принимающий как запросы так и ответы

И хранит словарь рефок в стейте

так я уже писал, что его главный минус - это рельсовый майндсет в core team

Генсервер в эликсире может noreply?

ну конечно может, это ж генсервер

Тогда получится известнейший боттлнек в генсервере

Пул ген серверов )

И сами месаги можно не передавать в генсервер, передавать только рефки. И фиг загрузишь тогда этот ботлнек

Код на Elixir (в чате Эликсира не смогли пока подсказать).

Вот это работает (чтение из файла, вывод в stdout):

Port.open({:spawn, ~s[ffmpeg -i 1.jpg -vf "scale='min(400,iw)':min'(200,ih)':force_original_aspect_ratio=decrease" -loglevel quiet -f image2 pipe:1]}, [:use_stdio, :stream, :exit_status, :binary])
flush()

Это тоже работает (вывод в файл, чтение из stdin, но приходится слать :close, без этого не работает, висит-ждёт):

pid = Port.open({:spawn, ~s[ffmpeg -i pipe:0 -vf "scale='min(400,iw)':min'(200,ih)':force_original_aspect_ratio=decrease" -loglevel quiet -f image2 4.jpg]}, [:use_stdio, :stream, :exit_status, :binary])
{:ok, data} = File.read("1.jpg")
Port.command(pid, data, [])
send(pid, {self(), :close})
flush()

А вот попытка использовать stdin и stdout не работает (шлю :close, как в предыдущем примере, при этом идёт flush по stdin и stdout, но к этому моменту на stdout пусто, и data messages не идут, порт закрывается, ffmpeg пишет в stderr дебаг-инфо о входном и выходном потоках):

pid = Port.open({:spawn, ~s[ffmpeg -i pipe:0 -vf "scale='min(400,iw)':min'(200,ih)':force_original_aspect_ratio=decrease" -loglevel verbose -f image2 pipe:1]}, [:use_stdio, :stream, :exit_status, :binary])
{:ok, data} = File.read("1.jpg")
Port.command(pid, data, [])
send(pid, {self(), :close})
flush()