def send_object(o)
  chunks = @encoder.encode(o)
  send_one_chunk = proc{
    if chunk = chunks.get_chunk
      send_data(chunk)
      EM.next_tick(send_one_chunk)
    end
  }
  send_one_chunk.call
end