             [onyx.plugin.onyx-output :as o]
             [onyx.plugin.onyx-plugin :as p]))
 
-(defrecord AbsSeqReader [event completed? sequential rst segment offset]
+(defrecord AbsSeqReader [event sequential rst segment offset]
   p/OnyxPlugin
 
   (start [this]

    offset)

  (recover [this checkpoint]
    (assoc this :sequential (drop (inc checkpoint) sequential)))

  (offset-id [this]
    offset)

      (assoc this
             :segment segment
             :rst remaining
             :offset (if segment (inc offset) offset))))

  (segment-complete! [this segment])

  (completed? [this]
    (empty? rst)))

(defn input [event]
  (map->AbsSeqReader {:event event}))
