     :onyx/batch-size batch-size
     :onyx/doc "Writes segments to a core.async channel"}])
 
+;;; Input data to pipe into the input channel, plus the
+;;; sentinel to signal the end of input.
 (def input-segments
   [{:sentence "Hey there user"}
    {:sentence "It's really nice outside"}
    {:sentence "I live in Redmond"}
    :done])
 
+;;; Put the data onto the input chan
 (doseq [segment input-segments]
   (>!! input-chan segment))
 


(defn question [segment]
  {:word (question-impl (:word segment))})

(def workflow
  {:input

            [onyx.plugin.core-async]
            [onyx.api]))

;;;;; Implementation functions ;;;;;
(defn split-by-spaces-impl [s]
  (clojure.string/split s #"\s+"))

