 
 (defn pyin-content [execution-count message]
   {:execution_count execution-count
-   :code (get-in message [:content :code])})
+   :code            (get-in message [:content :code])})
 
 (defn pyout-content [execution-count message executer]
   {:execution_count execution-count
-   :data {:text/plain (pr-str (eval (read-string (get-in message [:content :code]))))}
-   :metadata {}
+   :data            {:text/plain (pr-str (eval (read-string (get-in message [:content :code]))))}
+   :metadata        {}
    })
 
 

        (send-message iopub-socket "pyin" (pyin-content @execution-count message)
                      parent-header {} session-id)
        (send-message shell-socket "execute_reply"
                      {:status "ok"
                       :execution_count @execution-count
                       :user_variables {}
                       :payload [{}]
                       :user_expressions {}}
                      parent-header
                      {:dependencies_met "True"
                       :engine session-id
                       :status "ok"
                       :started (now)} session-id)
        (send-message iopub-socket "pyout"  (pyout-content @execution-count
                                                           message executer)
                      parent-header {} session-id)
        (send-message iopub-socket "status" (status-content "idle")
                      parent-header {} session-id)))))


(defn read-until-delimiter [socket]
  (let [preamble (doall (drop-last
                          (take-while (comp not #(= "<IDS|MSG>" %))
                                      (repeatedly #(read-blob socket)))))]
    ;    (println "PREABMLE:" preamble)
    preamble))

(defn new-header [msg_type session-id]
  {:date     (now)
   :msg_id   (uuid)
   :username "kernel"
   :session  session-id
   :msg_type msg_type})

(defn status-content [status]
