Vadim

Some graphics I made on #aleph slack in relation to a [discussion about error handling](https://clojurians-log.clojureverse.org/aleph/2017-09-18.html) - didn't get any response from @ztellman at a time, so attaching [here](https://imgur.com/a/2Q30I).

@lvh, do you mean something like ```clojure (require '[manifold.deferred :as m.d]) (defprotocol DeferredSemaphore (acquire [_]) (release [_])) (defn deferred-semaphore [tokens] (let [^java.util.LinkedList waiting (java.util.LinkedList.) tokens-remaining (volatile! tokens) acquired! #(do (vswap!...

@lvh so a `(semaphore-stream n-tokens)` would return a Source stream which could produce at most `n-tokens` deferreds at any given time. Once a consumer realizes a token (deferred), the stream...

@hansenpansen Just noticed that the code above is incorrect. `dsts` binding in the `d/loop` and in `(send! dsts result)` should be changed to `dst`.

Hey, I was the one who answered the question. @lxsameer - would be interesting to hear how you thought the streams worked and what your initial design was based on...

@mfikes isn't it a 0.55 slowdown relative to RC12?

Sorry, this is definitely the right description technically. I expect more people to be tripped up by the positive (speedup) + negative (0.55 < 1) though.

I understand this change is somewhat misguided. Would you be willing to discuss alternative (better) means of achieving the same result? The use-case is to hard-limit the size of files...

I inferred that incorrectly from the lack of activity on your part :) Sorry. I think this patch is the simplest implementation considering we're using the _commons-fileupload_, although it does...

Closing the `FileItem`'s input stream will skip to the next file on the main request input stream. I'm not sure I follow your approach.