     (s/connect stream-out-ch s)
     {:in stream-in-ch
      :out stream-out-ch}))
-
-(defn send-byte-array [^bytes b-a]
-  (let [stream-out-ch (:out @client)]
-    (if stream-out-ch
-      (>!! stream-out-ch b-a)
-      false)))
-
-(defn receive-byte-array []
-  (let [stream-in-ch (:in @client)]
-    (<!! stream-in-ch)))
 
 
 (def pending-requests (atom {}))


(defn io-assoc
  ([^String entity-id key value]
   (tcp-request-responce (io-assoc-base entity-id key value)))
  ([^String entity-id key value callback]
   (let [{:keys [b-a request-uuid]} (io-assoc-base entity-id key value)]
     (>!! tcp-request-ch {:b-a b-a :request-uuid request-uuid :callback callback}))))

(defn dispatch-to-type [value]
  (util/serialize value))

(def callback-count (atom 0))

(defn callback-test [responce-data]
