log3.clj

(defn iteration->seq
  [iteration]
  (seq
   (reify java.lang.Iterable 
     (iterator [this] 
       (reify java.util.Iterator
         (hasNext [this] (.hasNext iteration))
         (next [this] (.next iteration))
         (remove [this] (.remove iteration)))))))

(defn logs-seq
  "Convert a docker-client ^LogStream to a seq of lines."
  [logs]
  (let [it (iteration->seq logs)
        content (map #(.toString (.decode StandardCharsets/UTF_8 (.content ^LogMessage %))) it)]
    (mapcat #(string/split % #"\n") content)))