                                                     server-to-client-ch)
                         cresult (atake tn cs)
                         sresult (atake tn ss)]
-                    (do (println cresult)
-                        (println sresult)
+                    (do (println "client result" cresult)
+                        (println "server result" sresult)
                         (println server)
                         (println client)
                         true)))

(defrecord TestNPRServer [server]
  NPRServer
  (server-take-snapshot [this actx stream-request prev-snapshot]
    (println "server-take-snapshot" stream-request prev-snapshot)
    (let [start-sq (max (cbfg.npr/stream-request-start-sq stream-request)
                        (if prev-snapshot
                          (cbfg.npr/snapshot-next-sq prev-snapshot)
                          -1))]
      (println "server-take-snapshot start-sq" start-sq)
      (when (< start-sq (count (:items @server)))
        (let [items (nthnext (:items @server) start-sq)]
          (when (> (count items) 0)
            (println "server-take-snapshot2 start-sq" start-sq "items" items)
            (TestNPRSnapshot. {:items items
                               :next-sq (+ start-sq (count items))})))))))


(defrecord TestNPRStreamRequest [stream-request]
  NPRStreamRequest
  (stream-request-snapshot-beg-msg [this snapshot]
    (merge stream-request {:status :part :sub-status :snapshot-beg
                           :snapshot snapshot}))
  (stream-request-snapshot-end-msg [this snapshot]
    (merge stream-request {:status :part :sub-status :snapshot-end
                           :snapshot snapshot}))
  (stream-request-snapshot-item-msg [this snapshot item]
    (merge stream-request {:status :part :sub-status :snapshot-item
                           :snapshot snapshot
                           :item item}))
  (stream-request-rollback-msg [this rollback-info]
    (merge stream-request {:status :rollback
                           :rollback-info rollback-info}))
  (stream-request-start-sq [this]
