Fork me on GitHub
#clojure-dev
<
2015-09-08
>
angusiguess12:09:50

Have run into this issue using mixes with core.async:

angusiguess12:09:54

If a large number of channels are added to a mix, core.async throws this error:

java.lang.AssertionError: Assert failed: No more than 1024 pending puts are allowed on a single channel. Consider using a windowed buffer.

angusiguess12:09:26

Appears that the put! used it indicate the mix has changed can queue up and trip the assertion.

angusiguess12:09:03

But couldn't the change channel be backed by a sliding buffer with size one?

angusiguess12:09:10

Is this the right place to report this?