{"action":"closed","issue":{"url":"https://api.github.com/repos/ztellman/aleph/issues/201","labels_url":"https://api.github.com/repos/ztellman/aleph/issues/201/labels{/name}","comments_url":"https://api.github.com/repos/ztellman/aleph/issues/201/comments","events_url":"https://api.github.com/repos/ztellman/aleph/issues/201/events","html_url":"https://github.com/ztellman/aleph/issues/201","id":124100370,"number":201,"title":"byte array truncation in tcp transportation","user":{"login":"shisoft","id":3405885,"avatar_url":"https://avatars.githubusercontent.com/u/3405885?v=3","gravatar_id":"","url":"https://api.github.com/users/shisoft","html_url":"https://github.com/shisoft","followers_url":"https://api.github.com/users/shisoft/followers","following_url":"https://api.github.com/users/shisoft/following{/other_user}","gists_url":"https://api.github.com/users/shisoft/gists{/gist_id}","starred_url":"https://api.github.com/users/shisoft/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/shisoft/subscriptions","organizations_url":"https://api.github.com/users/shisoft/orgs","repos_url":"https://api.github.com/users/shisoft/repos","events_url":"https://api.github.com/users/shisoft/events{/privacy}","received_events_url":"https://api.github.com/users/shisoft/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"milestone":null,"comments":1,"created_at":"2015-12-28T18:04:44Z","updated_at":"2015-12-28T18:52:09Z","closed_at":"2015-12-28T18:52:09Z","body":"I am using nippy to serialize clojure data and send to tcp servers. As the example provided with some modifaction. I found that when the data is less than 1024 bytes, everything is fine. When above, I can only get 1024 bytes at server. \r\nI think this problem is 2-way, when the request data is small and the responses are big, client cannot decode data either.\r\n\r\n\r\nHere is the wrapper I use.\r\n```\r\n(defn wrap-duplex-stream\r\n  [s]\r\n  (let [out (s/stream)]\r\n    (s/connect out s)\r\n    (s/splice out s)))\r\n\r\n(defn client\r\n  [host port]\r\n  (d/chain (tcp/client {:host host, :port port})\r\n           #(wrap-duplex-stream %)))\r\n\r\n(defn start-server\r\n  [handler port]\r\n  (tcp/start-server\r\n    (fn [s info]\r\n      (handler (wrap-duplex-stream s) info))\r\n    {:port port}))\r\n```"}}