                                       (merge res-m {:partial :not-found :key key}))))
                             (aput multi-get res-ch
                                   (merge res-m {:status :ok}))))
-                     [state nil])]
+                     nil)]
        (act multi-get-start actx
          (aput multi-get-start state-ch
                [(kvs-ident-check (:kvs-ident m) work-fn) nil]))))

               (merge m (or (atake state-work done-ch)
                            {:status :error :status-info :closed-ch})))))

(def op-handlers
  {:kvs-open
   (fn [actx state-ch m]

    ; Using kvs-mgr-state to avoid atoms, which prevent time-travel.
    (act-loop kvs-mgr-state actx [state { :next-uuid 0 :kvss {} }]
              (if-let [[state-fn done-ch] (atake kvs-mgr-state state-ch)]
                (let [[next-state done-res] (state-fn state)]
                  (when (and done-ch done-res)
                    (aput-close kvs-mgr-state done-ch done-res))
                  (recur (or next-state state)))
                (println :kvs-mgr-state-ch-exit)))
    cmd-ch))
