lib/rainbows/xepoll_thread_pool/client.rb in rainbows-3.4.0 vs lib/rainbows/xepoll_thread_pool/client.rb in rainbows-4.0.0

@@ -109,11 +109,10 @@
     case kgio_tryread(CLIENT_HEADER_BUFFER_SIZE, buf)
     when :wait_readable
       return kato_set
     when String
       kato_delete
-      @hp.buf << buf
-      @hp.parse and return queue!
+      @hp.add_parse(buf) and return queue!
     else
       return close
     end while true
     rescue => e
       handle_error(e)