anchor.diff:      fetch_docs(DocName, Conn, Bucket, Kst, Opts) ++ Acc
     end,
     case stream_keys(Conn, Bucket, Get, []) of
  -    {ok, Docs} -> {ok, Docs, State};
  -    {_, Docs}  -> {error, Docs, State}
  +    {ok, Docs}             -> {ok, Docs, State};
  +    {error, Reason, Count} -> {error, {stream_keys, Reason, Count}, State}
     end.
   
   -spec find_all(DocName, SortFields, Limit, Offset, State) -> Response when
  
positive.code:     undefined ->
        case update_map(Conn, Bucket, undefined, doc_to_rmap(Doc), Opts) of
          {ok, RiakMapId} -> RiakMapId;
          {error, Error}  -> throw(Error);
          _               -> throw(unexpected)
        end;
      Id0 ->
        sumo_utils:to_bin(Id0)
  
negative.code:     Acc + length(Kst)
    end,
    case stream_keys(Conn, Bucket, Del, 0) of
      {ok, Count}            -> {ok, Count, State};
      {error, Reason, Count} -> {error, {stream_keys, Reason, Count}, State}
    end.
  
  -spec find_all(DocName, State) -> Response when
  