        ([result record]
         (if (keep-record? record filter-state)
           (xf result record)
-          result))))))
+          (do
+            (>!! progress-chan [:dot])
+            result)))))))
 
 (defn- evaluate-output
   "Evaluates the output for the chunking process


(defn- process-output
  "Writes the records to the next output file and resets the record buffer"
  [{:keys [verbose
           records
           output-folder
           file-name
           output-paths

    (go-loop [value (<! progress-chan)]
             (case (first value)
               :record
               (print (-> value second meta :record-type name first))
               :dot
               (print ".")
               :message
               (println "\n" (second value)))
             (flush)
             (recur (<! progress-chan)))
    (println "reading the source file...")
    (<!! result)
