anchor.diff:  	meta = [] :: [{atom(), any()}],
   
   	%% Request body.
  -	body_state = waiting :: waiting | done
  -		| {stream, non_neg_integer(), fun(), any(), fun()},
  +	body_state = waiting :: waiting | done | {stream, non_neg_integer(),
  +		transfer_decode_fun(), any(), content_decode_fun()},
   	multipart = undefined :: undefined | {non_neg_integer(), fun()},
   	buffer = <<>> :: binary(),
   
  
positive.code: -type cookie_opts() :: [cookie_option()].
  -export_type([cookie_opts/0]).
  
  -type resp_body_fun() :: fun((inet:socket(), module()) -> ok).
  -type send_chunk_fun() :: fun((iodata()) -> ok | {error, atom()}).
  -type resp_chunked_fun() :: fun((send_chunk_fun()) -> ok).
  
negative.code: 		headers=Headers3, p_headers=PHeaders3}.
  
  %% @todo Probably needs a Rest.
  -spec content_decode(content_decode_fun(), binary(), Req)
  	-> {ok, binary(), Req} | {error, atom()} when Req::req().
  content_decode(ContentDecode, Data, Req) ->
  	case ContentDecode(Data) of
  