anchor.diff:      undefined ->
         case update_map(Conn, Bucket, undefined, doc_to_rmap(Doc), Opts) of
           {ok, RiakMapId} -> RiakMapId;
  -        {error, Error}  -> throw(Error);
  -        _               -> throw(unexpected)
  +        {error, Error}  -> exit(Error);
  +        Unexpected      -> exit({unexpected, Unexpected})
         end;
       Id0 ->
         sumo_utils:to_bin(Id0)
  
positive.code:     Acc + length(Kst)
    end,
    case stream_keys(Conn, Bucket, Del, 0) of
      {ok, Count} -> {ok, Count, State};
      {_, Count}  -> {error, Count, State}
    end.
  
  -spec find_all(DocName, State) -> Response when
  
negative.code: %% @private
  receive_stream(Ref, F, Acc) ->
    receive
      {Ref, {_, Keys, _}} ->
        receive_stream(Ref, F, F(Keys, Acc));
      {Ref, {done, _Continuation = undefined}} ->
        {ok, Acc};
      Unexpected ->
        {error, {unexpected, Unexpected}, Acc}
    after
      30000 -> {error, timeout, Acc}
    end.
  
  %% @private
  