       (strm/consume (partial client-child-processor
                              client-atom
                              client-state
+                             succeeded?
                              chzbrgr-length)
                     clnt-decode-sink)
       (strm/consume (partial server-child-processor
                              server-atom
                              server-state-atom
-                             succeeded?
                              chzbrgr-length)
                     srvr-decode-sink)
 

    bs))

(defn server-child-processor
  [server-atom state-atom succeeded? chzbrgr-length incoming]
  (is incoming)
  (is (or (keyword? incoming)
          (and (bytes? incoming)


(defn client-child-processor
  "Process the messages queued by mock-client-child"
  [client-atom client-state-atom succeeded? chzbrgr-length incoming]
  (is incoming)
  (is (or (keyword? incoming)
          ;; Implementation detail:
