anchor.diff:      {{known_length_stream, ContentLength, {<<>>, StreamFun}}, NewRQ, Ctx}.
   
   %% @doc Callback for deleting an object.
  --spec delete_resource(term(), term()) -> boolean().
  +-spec delete_resource(term(), term()) -> {true, term(), #key_context{}}.
   delete_resource(RD, Ctx=#key_context{bucket=Bucket,
                                        key=Key,
                                        get_fsm_pid=GetFsmPid,
  
positive.code:              User?MOSS_USER.key_id},
              Owner,
              RiakPid),
      Args = [Bucket, list_to_binary(Key), Size, list_to_binary(ContentType),
          Metadata, BlockSize, ACL, timer:seconds(60), self(), RiakPid],
      {ok, Pid} = riak_moss_put_fsm_sup:start_put_fsm(node(), Args),
      accept_streambody(RD, Ctx, Pid, wrq:stream_req_body(RD, riak_moss_lfs_utils:block_size())).
  
  accept_streambody(RD, Ctx=#key_context{size=0}, Pid, {_Data, _Next}) ->
  
negative.code:             DocCtx = riak_moss_wm_utils:ensure_doc(Ctx),
              ContentType = binary_to_list(Mfst#lfs_manifest_v2.content_type),
              case ContentType of
                  _ ->
                      {[{ContentType, produce_body}], RD, DocCtx}
              end;
  