         (let [log-state
               (if (< start contiguous-stream-count)
                 (let [bytes-to-skip (- contiguous-stream-count start)
-                      log-state (log2/info log-state
-                                           ::consolidate-message-block
-                                           (str "Skipping "
-                                                bytes-to-skip
-                                                " previously received bytes in "
-                                                buf))]
+                      log-state (log/info log-state
+                                          ::consolidate-message-block
+                                          (str "Skipping "
+                                               bytes-to-skip
+                                               " previously received bytes in "
+                                               buf))]
                   (.skipBytes buf bytes-to-skip)
                   log-state)
                 log-state)
-              log-state (log2/debug log-state
-                                    ::consolidate-message-block
-                                    (str "Consolidating entry 1/"
-                                         (count (::specs/gap-buffer
-                                                 incoming))))]
+              log-state (log/debug log-state
+                                   ::consolidate-message-block
+                                   (str "Consolidating entry 1/"
+                                        (count (::specs/gap-buffer
+                                                incoming))))]
           (-> state
               (update ::specs/incoming
                       (fn [cur]

  ;; Maybe I should add an optional parameter during startup:
  ;; if you don't provide
  ;; this, it will default to calling this.
  [{:keys [::log2/logger
           ::specs/child-in
           ::specs/message-loop-name]
    trigger ::specs/from-parent-trigger

    (let [bs (byte-array (.readableBytes buf))
          n (count bs)]
      (.readBytes buf bs)
      (let [{:keys [::log/lamport]
             :as log-state} (log/info log-state
                                      ::write-bytes-to-child-stream!
                                      (str "Signalling child's input loop with "
                                           n
                                           " bytes"))
            log-state
            (try
              (let [start-time (System/currentTimeMillis)]
