 
 (defn read-until-delimiter [socket]
   (let [preamble (doall (drop-last
-                         (take-while (comp not #(= "<IDS|MSG>" (try-convert-to-string %)))
+                         (take-while (comp not #(= "<IDS|MSG>"
+                                                   (try-convert-to-string %)))
                                      (repeatedly #(zmq/receive socket)))))]
     preamble))
 

                                  :engine session-id
                                  :status "ok"
                                  :started (now)} session-id signer (:idents message))

            ;; Send stdout
            (send-message iopub-socket "pyout"
                          {:execution_count @execution-count

                      parent-header {} session-id signer)
        (send-message iopub-socket "pyin" (pyin-content @execution-count message)
                      parent-header {} session-id signer)
        (try
          (let [s# (new java.io.StringWriter) [output results]
              (binding [*out* s#]
                (let [result (pr-str (eval (load-string
                                            (get-in message [:content :code]))))
                      output (str s#)]
                  [output, result]))]
            (send-router-message shell-socket "execute_reply"
                                 {:status "ok"
                                  :execution_count @execution-count
