         ;; This is much slower than I'd like
         {:keys [::specs/outgoing
                 ::specs/recent]
-         :as state'} (time (from-child/consume-from-child start-state chzbrgr))]
+         :as state'} (time (from-child/process-next-bytes-from-child! start-state chzbrgr))]
     (is (= 1 (count (::specs/un-sent-blocks outgoing))))
     (is (= chzbrgr-lngth (::specs/strm-hwm outgoing)))
     (let [current-message  (-> outgoing

                (when-not (= outcome ::timeout)
                  (let [result-buffer (:buffer outcome)]
                    (is (= packet-count (count result-buffer)))
                    (is (= K/initial-max-block-length (count (first result-buffer))))
                    (doseq [packet (butlast result-buffer)]
                      (is (= (count packet) K/k-div2)))
                    (let [final (last result-buffer)]

                                           byte-array)
                                      (->> message-body
                                           vec
                                           (take K/max-bytes-in-initiate-message)
                                           byte-array))))))))))
        (let [{:keys [::specs/incoming
                      ::specs/outgoing]
