У меня есть канал, выступающий в роли издателя: (def publisher (async/chan)) (def publication (async/pub publisher :topic)) Из-за характера sub/pub , когда я делаю это: (async/put! publisher {:topic :foo}) Сообщение потребляется...

Из http://martintrojer.github.io/clojure/2013/07/07/coreasync-and-blocking-io/ : Чтобы получить более конкретную информацию, давайте посмотрим, что происходит, когда мы пытаемся выполнить какой-либо HTTP-запрос GET, используя core.async....

Допустим, у меня есть набор вычислений, которые я хочу выполнять асинхронно с помощью core.async, но, к сожалению, некоторые функции зависят от вывода других функций. Как я могу четко структурировать это в своем коде, а также добиться максимальной...

У меня есть несколько потоков, возвращенных core.async/thread , вовлеченных в какой-то процесс, который я собираюсь закрыть. Я не закрываю всю свою программу, только эти потоки. Как я могу завершить потоки? Метод .stop класса Java Thread...