Size: a a a

Clojure — русскоговорящее сообщество

2020 November 09

MB

Mikhail Borisov in Clojure — русскоговорящее сообщество
Вроде же есть мультикаст ченнелы или что то такое?
источник

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество
Mikhail Borisov
Вроде же есть мультикаст ченнелы или что то такое?
да вроде сложно получится
нужен будет канал для каждого сокета, в который будет происходить мультикаст, и на каждом канале нужно сидеть и ждать оттуда «свой» экземпляр сообщения
это насколько я понимаю
источник

AC

Alexey Cheremisin in Clojure — русскоговорящее сообщество
Наверное сделаю атом с вотчерами, а вотчер оберну в async/go, чтобы нетормозиллсь...
источник

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество
Alexey Cheremisin
Наверное сделаю атом с вотчерами, а вотчер оберну в async/go, чтобы нетормозиллсь...
а что, отправка в сокет не асинхронная?
источник

AC

Alexey Cheremisin in Clojure — русскоговорящее сообщество
Sergey Trofimov
а что, отправка в сокет не асинхронная?
Хрен его знает, как там подписки на websocket у lacinia...
источник

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество
Alexey Cheremisin
Хрен его знает, как там подписки на websocket у lacinia...
не, ну нужно знать, зачем наугад стрелять 😊
источник

AC

Alexey Cheremisin in Clojure — русскоговорящее сообщество
Лучше перебдеть иногда... ибо подвисший сокет хуже
источник

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество
это ж не чёрная магия 😊
источник

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество
Alexey Cheremisin
Лучше перебдеть иногда... ибо подвисший сокет хуже
перебдишь, что весь core.async подвесишь, и тоже будет плохо 😊
источник

AC

Alexey Cheremisin in Clojure — русскоговорящее сообщество
Ну... убрать-то просто...
источник

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество
Alexey Cheremisin
Наверное сделаю атом с вотчерами, а вотчер оберну в async/go, чтобы нетормозиллсь...
в go, кстати, нельзя блокирующие операции запихивать
источник

AC

Alexey Cheremisin in Clojure — русскоговорящее сообщество
Sergey Trofimov
в go, кстати, нельзя блокирующие операции запихивать
да, аргумент! там еще async/thread есть
источник

AC

Alexey Cheremisin in Clojure — русскоговорящее сообщество
и может кто с manifold дело имел?
источник

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество
Alexey Cheremisin
да, аргумент! там еще async/thread есть
тогда и go не нужен
тот же эффект от future будет
источник

AC

Alexey Cheremisin in Clojure — русскоговорящее сообщество
Sergey Trofimov
тогда и go не нужен
тот же эффект от future будет
ага! спасибо! буду пробовать
источник

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество
Alexey Cheremisin
ага! спасибо! буду пробовать
на самом деле тоже плохой вариант тупо тысячи future вызывать единомоментно 😊
источник

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество
я бы всё же разобрался, асинхронная ли отправка данных в сокет
я удивлюсь, если синхронная
источник

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество
Alexey Cheremisin
Хрен его знает, как там подписки на websocket у lacinia...
ты про клиент тут пишешь?
я вообще-то про серверную часть говорил
источник

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество
Sergey Trofimov
ты про клиент тут пишешь?
я вообще-то про серверную часть говорил
и какой-то streamer у них там описан...
источник

AC

Alexey Cheremisin in Clojure — русскоговорящее сообщество
Sergey Trofimov
ты про клиент тут пишешь?
я вообще-то про серверную часть говорил
Не, я про сервер! у меня сервер, который работает с клиентами через websockets (на основе lacinia и pedestal-jetty). Клиент коннектится к серверу, а меня на сервере срабатывает коллбек, получаю websocket-stream.
источник