anchor.diff:  process_stream(_,_,State) ->
       {ignore, State}.
   
  -
   %% ---------------------------------
   %% Internal functions
   %% ---------------------------------
  
positive.code: 
  encode_results({NumFound, MaxScore, {ids, IDs}}, UK, _FL) ->
      #rpbsearchqueryresp{
                  docs = [ encode_search_doc({UK, ID}) || ID <- IDs ],
                  max_score = to_float(MaxScore),
                  num_found = NumFound
                  };
  
negative.code:             {ok, FilterOps} = Client:parse_filter(Schema, SQuery#squery.filter),
              %% Validate
              UK = Schema:unique_key(),
              FL = parse_fl(default(FL0, [<<"*">>])),
              Sort = default(Sort0, <<"none">>),
              Presort = to_atom(default(Presort0, <<"score">>)),
              if
  