 
 (defn start-commit-loop! [commit-ch log k]
   (go-loop []
-           (when-let [content (<!! commit-ch)] 
+           (when-let [content (<!! commit-ch)]
              (extensions/force-write-chunk log :chunk content k)
              (recur))))
 

        (reset! top-acked-tx new-top-acked))
      (swap! pending-messages dissoc segment-id)))

  (retry-segment 
    [_ event segment-id]
    (when-let [msg (get @pending-messages segment-id)]
      (>!! read-ch (assoc msg :id (java.util.UUID/randomUUID))))

    [_ _ segment-id]
    (get @pending-messages segment-id))

  (drained?
    [_ _]
    @drained?))

