Skip to content

Commit 7047022

Browse files
committed
Merge branch 'master' into dev-vthreads-exec
2 parents e60d508 + 7cc715a commit 7047022

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

docs/clojure.core.async.flow.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,7 @@
200200
</pre></div></div><div class="public anchor" id="var-start"><h3>start</h3><div class="usage"><code>(start g)</code></div><div class="doc"><pre class="plaintext">starts the entire flow from init values. The processes start paused.
201201
Call 'resume' or 'resume-proc' to start flow. Returns a map with keys:
202202

203-
:report-chan - a core.async chan for reading.'ping' reponses
203+
:report-chan - a core.async chan for reading.'ping' responses
204204
will show up here, as will any explicit ::flow/report outputs
205205
from :transform
206206

src/main/clojure/clojure/core/async/impl/channels.clj

+7-5
Original file line numberDiff line numberDiff line change
@@ -309,8 +309,10 @@
309309
ManyToManyChannel
310310
(datafy [c]
311311
(let [b (.buf c)]
312-
(cond->
313-
{:put-count (count (.puts c))
314-
:take-count (count (.takes c))
315-
:closed? (impl/closed? c)}
316-
b (assoc :buffer (clojure.datafy/datafy b))))))
312+
(with-meta
313+
(cond->
314+
{:put-count (count (.puts c))
315+
:take-count (count (.takes c))
316+
:closed? (impl/closed? c)}
317+
b (assoc :buffer (datafy/datafy b)))
318+
{::datafy/obj c}))))

0 commit comments

Comments
 (0)