Close client Netty channel on malformed request

Add some docstrings

Author: KingMob

src/aleph/http/client.clj

@@ -555,14 +555,15 @@
                             (reset! save-body body))
 
                           (-> (netty/safe-execute ch
-                                                  (http/send-message ch true ssl? req' body))
+                                (http/send-message ch true ssl? req' body))
                               (d/catch' (fn [e]
                                           (s/put! responses (d/error-deferred e))
                                           (netty/close ch))))))
 
                       ;; this will usually happen because of a malformed request
                       (catch Throwable e
-                        (s/put! responses (d/error-deferred e)))))
+                        (s/put! responses (d/error-deferred e))
+                        (netty/close ch))))
                   requests)
 
                 (s/on-closed responses

src/aleph/http/core.clj

@@ -509,6 +509,12 @@
             (d/catch' (fn [_]))))]
 
   (defn send-message
+    "Write an HttpMessage and body to a Netty channel.
+
+     Accepts Strings, ByteBuffers, ByteBufs, byte[], ChunkedInputs,
+     Files, Paths, HttpFiles, seqs and streams for bodies.
+
+     Seqs and streams must be, or be coercible to, a stream of ByteBufs."
     [ch keep-alive? ssl? ^HttpMessage msg body]
 
     (let [f (cond

src/aleph/netty.clj

@@ -272,7 +272,12 @@
     x
     (.channel ^ChannelHandlerContext x)))
 
-(defmacro safe-execute [ch & body]
+(defmacro safe-execute
+  "Executes the body on the event-loop (an executor service) associated with the Netty channel.
+
+   Executes immediately if current thread is in the event loop. Otherwise, returns a deferred
+   that will hold the result once done."
+  [ch & body]
   `(let [f# (fn [] ~@body)
          event-loop# (-> ~ch aleph.netty/channel .eventLoop)]
      (if (.inEventLoop event-loop#)