aleph

dm3 2017-07-15T05:43:56.139500Z

the thread executing callbacks is the same one doing stream/put!

dm3 2017-07-15T05:44:54.142273Z

if the consumer is already waiting with a corresponding stream/take!

dm3 2017-07-15T05:46:21.146761Z

unless there’s a separate executor specified with stream/onto

dm3 2017-07-15T05:47:05.148857Z

stream is marked as drained by the thread doing stream/take! or the one doing stream/close!

dm3 2017-07-15T05:52:03.163442Z

so that’s the thread that’s going to invoke the on-drained callback