anchor.diff:                      %    [Index, Field, Term]),
                       self() ! {CatRef, {Partition, Index, Field, Term, JSONProps}},
                       fold_catalog_process(CatRef, FoldResultPid, CatalogDone,
  -                                         StreamProcessCount, FinishedStreamProcessCount, true);
  +                                         StreamProcessCount, 
  +                                         FinishedStreamProcessCount,
  +                                         true, Conn);
                   false ->
                       spawn_link(fun() ->
                           %% io:format("fold_catalog_process: catalog_query_response: ~p: ~p.~p.~p (~p)~n",
  
positive.code:                            {ok, StreamRef} = raptor_conn:multi_stream(
                                                 Conn,
                                                 list_to_binary(TermArg)),
                             receive_stream_results(StreamRef, Sender, FilterFun)
                         after
                             riak_sock_pool:checkin(?CONN_POOL, Conn)
                         end
  
negative.code:         riak_sock_pool:checkin(?CONN_POOL, Conn)
      end.
  
  receive_stream_results(StreamRef, Sender, FilterFun, Conn) ->
      receive_stream_results(StreamRef, Sender, FilterFun, Conn, []).
  
  receive_stream_results(StreamRef, Sender, FilterFun, Conn, Acc0) ->
      case length(Acc0) > ?RESULT_VEC_SZ of
          true ->
              riak_search_backend:stream_response_results(Sender, Acc0),
  