anchor.diff:  -define(STREAM_SIZE, 100).
   
   stream(Index, Field, Term, FilterFun, Sender, State) ->
  +    multi_stream([{term, {Index, Field, Term}, []}],
  +                 FilterFun, Sender, State).
  +
  +multi_stream(IFTList, FilterFun, Sender, State) ->
       spawn(riak_search_ets_backend, stream_results,
             [Sender,
              FilterFun,
              ets:select(State#state.table,
  -                      [{{{b(Index),b(Field),b(Term)},'$1'},[],['$1']}],
  +                      [{{{b(I), b(F), b(T)}, '$1'}, [], ['$1']}
  +                       || {term, {I, F, T}, _P} <- IFTList],
                         ?STREAM_SIZE)]),
       noreply.
   
  
positive.code:     riak_search_backend:info_response(Sender, [{Term, node(), Count}]),
      noreply.
  
  %%% TODO: I've never actually seen info_range/7 get executed
  info_range(Index, Field, StartTerm, EndTerm, _Size, Sender, State) ->
      Terms = find_terms_in_range(b(Index), b(Field),
                                  b(StartTerm), b(EndTerm),
  
negative.code:     noreply.
  %%% TODO: why can't I {reply, ok} here? (cargo-cult raptor_backend)
  
  info(Index, Field, Term, Sender, State) ->
      Count = ets:select_count(State#state.table,
                               [{{{b(Index), b(Field), b(Term)}, '_'},
  