              (= (:status r) :ok) (aput-close npr-client-loop out {:status :ok})
              (and snapshot-beg
                   (= (:status r) :part)
-                  (= (:sub-status r) :snapshot-item)) (if-let [err (client-snapshot-item npr-client-loop client
+                  (= (:sub-status r) :snapshot-item)) (if-let [err (client-snapshot-item client
+                                                                                         npr-client-loop
                                                                                          stream-request
                                                                                          snapshot-beg r)]
                                                         (aput-close npr-client-loop out err)

                                                               num-snapshots (inc num-items)))
             (and snapshot-beg
                  (= (:status r) :part)
                  (= (:sub-status r) :snapshot-end)) (if-let [err (client-snapshot-end npr-client-loop client
                                                                                       stream-request
                                                                                       snapshot-beg r)]
                                                       (aput-close npr-client-loop out err)

                                                              (inc num-snapshots) num-items))
             (and (nil? snapshot-beg)
                  (= (:status r) :part)
                  (= (:sub-status r) :snapshot-beg)) (if-let [err (client-snapshot-beg client
                                                                                       npr-client-loop
                                                                                       stream-request r)]
                                                       (aput-close npr-client-loop out err)
                                                       (recur stream-request r
