anchor.diff:                  Results ++ [{Term, node(), Count}]);
           Msg ->
               riak_search_backend:info_response(Sender, [Results]),
  -            raptor_conn:close(Conn),
  +            exit(Conn, kill),
               throw({unexpected_msg, Msg})
       after
           ?INFO_RANGE_TIMEOUT ->
               riak_search_backend:info_response(Sender, Results),
  -            raptor_conn:close(Conn),
  +            exit(Conn, kill),
               error_logger:warning_msg("Info range result Raptor conn timeout\n")
       end,
       ok.
  
positive.code:             receive_catalog_query_results(StreamRef, Sender, Conn);
          Msg ->
              riak_search_backend:catalog_query_done(Sender),
              raptor_conn:close(Conn),
              throw({unexpected_msg, Msg})
      after
          ?CATALOG_QUERY_TIMEOUT ->   
              riak_search_backend:catalog_query_done(Sender),
              raptor_conn:close(Conn),
              error_logger:warning_msg("Catalog query result Raptor conn timeout\n")
      end,
      ok.
  
negative.code:     receive
          {catalog_query, _ReqId, timeout} ->
              riak_search_backend:catalog_query_done(Sender),
              exit(Conn, kill),
              error_logger:warning_msg("Catalog query result Raptor socket timeout\n");
          {catalog_query, _ReqId, "$end_of_results", _, _, _, _} ->
              riak_search_backend:catalog_query_done(Sender);
  