core.async

0зной

1ответ

Как сделать поток коллектора сбрасывающим буфером?

Использование core.async Я могу легко создать канал с капельным буфером: (async/chan (async/dropping-buffer 10)) Можно ли создать manifold поток с удалением буфера?

clojure core.async 2016-07-11

---

1зной

2ответ

Потребление содержимого файла с помощью core.async Clojure

Я пытаюсь использовать библиотеку Clojure core.async для использования/обработки строк из файла. Когда мой код выполняет IOException: Stream closed - это бросок. Ниже РЕПЛ сессии, которая воспроизводи

clojure core.async 2016-07-13

---

2зной

2ответ

Создавайте каналы, которые нужно закрывать несколько раз

Моя ситуация заключается в том, что один и тот же канал используется совместно между различными функциями, и мне нужно закрыть канал, когда все эти функции сигнализируют, что они сделаны с ним. Это то

clojure channel core.async 2016-06-01

---

1зной

1ответ

Как обрабатывать бесконечные поворотные петли

Как хобби проект, я работаю над alternate futures and promises implementation на основе "From Events to Futures and Promises and back". Оригинальный автор использует каналы/события под капотом, поэтом

clojure future core.async 2016-07-30

---

9зной

1ответ

Где утечка памяти, когда mapcat разрушает противодавление в core.async?

Я написал некоторый код core.async в Clojure, и когда я его запустил, он уничтожил всю доступную память и ошибся с ошибкой. Похоже, что использование mapcat в контуре core.async нарушает обратное давл

asynchronous memory-leaks clojure core.async backpressure 2016-06-21

---