anchor.diff:                  end;
           Msg ->
               FoldResultPid ! {fold_result, done},
  -            raptor_conn:close(Conn),
  +            exit(Conn, kill),
               throw({unexpected_msg, Msg})
   
           after ?FOLD_TIMEOUT ->
  -            raptor_conn:close(Conn),
  +            exit(Conn, kill),
               error_logger:warning_msg("Fold catalog Raptor conn timeout\n"),
               case FinishedStreamProcessCount >= (StreamProcessCount) of
                   true -> ok;
  
positive.code:     receive
          {catalog_query, _ReqId, timeout} ->
              riak_search_backend:catalog_query_done(Sender),
              raptor_conn:close(Conn),
              error_logger:warning_msg("Catalog query result Raptor socket timeout\n");
          {catalog_query, _ReqId, "$end_of_results", _, _, _, _} ->
              riak_search_backend:catalog_query_done(Sender);
  
negative.code:     receive
          {info, StreamRef, timeout} ->
              riak_search_backend:info_response(Sender, Results),
              exit(Conn, kill),
              error_logger:warning_msg("Info range result Raptor socket timeout\n");
  
          {info, StreamRef, "$end_of_info", 0} ->
  