anchor.diff:  is_empty(_State) ->
       true.
       % xxx TODO
  -
  -fold(State, Fun, Acc) ->
  -    io:format("fold(~p, ~p, ~p)~n",
  -        [State, Fun, Acc]),
  -    [].
       
  -fold2(State, Fun, Acc) ->
  -    ?PRINT({fold, State, Fun, Acc}),
  -    %% The supplied function expects a BKey and an Object. Wrap this
  -    %% So that we can use the format that merge_index expects.
  -    WrappedFun = fun(Index, Field, Term, SubType, SubTerm, Value, Props, TS, AccIn) ->
  -        ?PRINT({wrapped_fun, Index, Field}),
  -        %% Construct the object...
  -        IndexBin = riak_search_utils:to_binary(Index),
  -        FieldTermBin = riak_search_utils:to_binary([Field, ".", Term]),
  -        Payload = {index, Index, Field, Term, SubType, SubTerm, Value, Props, TS},
  -        BObj = term_to_binary(riak_object:new(IndexBin, FieldTermBin, Payload)),
  -        Fun({IndexBin, FieldTermBin}, BObj, AccIn)
  -    end,
  -    %%Pid = State#state.pid,
  -    %%{ok, FoldResult} = merge_index:fold(Pid, WrappedFun, Acc),
  -    %%FoldResult.
  -    ok.
  -
  -drop(State) ->
  +drop(_State) ->
       ok.
       %merge_index:drop(Pid).
       %%%% xxx TODO
  
positive.code:                 [StreamRef, OutputPid, OutputRef, Msg]),
              OutputPid ! []
      end,
  ok.
  
  
  %% @spec get(state(), BKey :: riak_object:bkey()) ->
  %%         {ok, Val :: binary()} | {error, Reason :: term()}
  
negative.code: -author("John Muellerleile <johnm@basho.com>").
  -export([start/2,stop/1,get/2,put/3,list/1,list_bucket/2,delete/2]).
  -export([fold/3, drop/1, is_empty/1]).
  -export([test_fold/0]).
  
  -include_lib("eunit/include/eunit.hrl").
  -include("riak_search.hrl").
  