MB
А что тут нужно сделать асинхронным?
Size: a a a
2021 January 26
AC
Я правильно понял, что нужно реализовать pub часть?
наобророт sub, и как правильно его приготовить
MB
Насколько я представляю, отправка сообщения в вебсокет неблокирующая. Тогда пройтись по всем сабскрайберам и кинуть им сообщения вроде нормально и в одном потоке
AC
есть один паблишер, есть куча сабов, сабы должны слать каждый в свой сокет (веб-сокет) , так как сокет может тормозить (и наверняка будет), то при срабатывании очередного события, я бы не хотел, чтобы все повисло на медленном сокете
MB
Насколько я представляю, отправка сообщения в вебсокет неблокирующая. Тогда пройтись по всем сабскрайберам и кинуть им сообщения вроде нормально и в одном потоке
Отправка сообщения в сокет неблокирующая?
AC
блокирующая наверное (вебсервер)
AC
очередей точно нет пока
MB
Ну если блокирующая, тогда можно наверное future или thread в вотчере запускать
MB
Но я на своей памяти не припомню блокирующей отправки в вебсокет)
AC
Вот что в документации
Typically, the streamer will create a thread, core.async process, or other long-lived construct to feed values to the source stream.
Typically, the streamer will create a thread, core.async process, or other long-lived construct to feed values to the source stream.
MB
Там же даже понятия "ответа" нет, зачем блокироваться то? Мне кажется стоит уточнить
MB
Вот что в документации
Typically, the streamer will create a thread, core.async process, or other long-lived construct to feed values to the source stream.
Typically, the streamer will create a thread, core.async process, or other long-lived construct to feed values to the source stream.
add-watch просто коллбэк будет вызывать, это точно не long-lived
AC
Там же даже понятия "ответа" нет, зачем блокироваться то? Мне кажется стоит уточнить
если атом, то мне достаточно прихранить сам инстанс сокета, тогда по идее, мне ничего не нужно... и оно работает...
AC
(def testa (atom nil))
(defn log-message-streamer
[context args source-stream]
;; Create an object for the subscription.
(add-watch testa source-stream
(fn [s a o n]
(source-stream n)))
#(remove-watch testa source-stream)
)
MB
Да вроде и должно) Надо бы только проверить (в идеале), что произойдет, если сокет на другой стороне тихо умрет, а сервер попытается отправить ему сообщение
AC
наверное лучше в feature завернуть...
MB
Мне кажется, будет либо ничего, либо эксепшн
AC
не, эксепшион не выпал, завернул в футуру
MB
Мне кажется, что футура все таки лишняя, но я на кофейной гуще гадаю)
AC
увы, я тоже... но кажется, если проблемы будут, то лучше пусть футура, чем дидлок