   ([event & events]
    (run! #(rx/push! bus %) (into [event] events))))
 
-(defn swap-state
+(defn swap
   "A helper for just apply some function to state
   without a need to declare additional event."
   [f]

    (-apply-update [_ state]
      (f state))))

(defn reset-state
  "A event that resets the internal state with
  the provided value."
  [state]

      (rx/subscribe $ (fn [[event model]] (-apply-effect event model))))

    ;; Initialize the stream machinary with initial state.
    (emit! (swap #(merge % state)))
    state-s))
