anchor.diff:    {})
   
   (defn after-read-batch [event lifecycle]
  -  (printn "Executing once after this batch has been read.")
  +  (println "Executing once after this batch has been read.")
  +  {})
  +
  +(defn after-apply-fn-batch [event lifecycle]
  +  (println "Executing once after the onyx/fn has been called on the input segments.")
     {})
   
   (defn after-batch [event lifecycle]
  
positive.code:    :lifecycle/before-task-start before-task-start
     :lifecycle/before-batch before-batch
     :lifecycle/after-read-batch after-read-batch
     :lifecycle/after-batch after-batch
     :lifecycle/after-task-stop after-task-stop
     :lifecycle/after-ack-segment after-ack-segment
  
negative.code: launched, but before the peer listens for incoming segments from other
  peers.
  
  ==== Before batch start
  
  A function that takes two arguments - an event map, and the matching
  lifecycle map. Must return a map that is merged back into the original
  event map. This function is called prior to receiving a batch of
  segments from the reading function.
  
  ==== After reading batch of segments
  
  A function that takes two arguments - an event map, and the matching
  lifecycle map. Must return a map that is merged back into the original
  