              ::specs/contiguous-stream-count]
      :as incoming} ::specs/incoming
     :keys [::specs/message-loop-name]
-    log-state ::log2/state
+    log-state ::log/state
     :as state}
    k-v-pair]
   (let [prelog (utils/pre-log message-loop-name)

                                                              (dec max-n)))]
                          (if (<= 0 n)
                            (let [holder (byte-array (inc n))
                                  my-log-state (log2/debug my-log-state
                                                           ::read-bytes-from-parent!
                                                           (str
                                                            (inc n)

        (let [log-state
              (if (< start contiguous-stream-count)
                (let [bytes-to-skip (- contiguous-stream-count start)
                      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 (log/debug log-state
                                   ::consolidate-message-block
                                   (str "Consolidating entry 1/"
                                        (count (::specs/gap-buffer
                                                incoming))))]
          (-> state
              (update ::specs/incoming
                      (fn [cur]
