anchor.diff:              receive_info_results(StreamRef, Sender, Conn);
           Msg ->
               riak_search_backend:info_response(Sender, []),
  -            raptor_conn:close(Conn),
  +            exit(Conn, kill),
               throw({unexpected_msg, Msg})
       after
           ?INFO_TIMEOUT ->           
               riak_search_backend:info_response(Sender, []),
  -            raptor_conn:close(Conn),
  +            exit(Conn, kill),
               error_logger:warning_msg("Info result Raptor conn timeout\n")
       end,
       ok.
  
positive.code:     receive
          {info, StreamRef, timeout} ->
              riak_search_backend:info_response(Sender, Results),
              raptor_conn:close(Conn),
              error_logger:warning_msg("Info range result Raptor socket timeout\n");
  
          {info, StreamRef, "$end_of_info", 0} ->
  
negative.code:                 Results ++ [{Term, node(), Count}]);
          Msg ->
              riak_search_backend:info_response(Sender, [Results]),
              exit(Conn, kill),
              throw({unexpected_msg, Msg})
      after
          ?INFO_RANGE_TIMEOUT ->
              riak_search_backend:info_response(Sender, Results),
              exit(Conn, kill),
              error_logger:warning_msg("Info range result Raptor conn timeout\n")
      end,
      ok.
  