anchor.diff:  read_size(<<>>, _, _) ->
       eof;
   
  +read_size(<<"\n", Rest/binary>>, Acc, _) ->
  +    {ok, lists:reverse(Acc), Rest};
  +
   read_size(<<"\r\n", Rest/binary>>, Acc, _) ->
       {ok, lists:reverse(Acc), Rest};
   
  
positive.code:             {error, closed};
          {ok, Size, Rest} ->
              case read_chunk(Rest, Size) of
                  {ok, <<"\r\n">>, Rest1} ->
                      parse_msgs(Rest1, Token, ContentType);
                  {ok, Chunk, Rest1} ->
  
negative.code: 
  read_chunk(Data, Size) ->
      case Data of
          <<Chunk:Size/binary, "\n", Rest/binary>> ->
              {ok, Chunk, Rest};
          <<Chunk:Size/binary, "\r\n", Rest/binary>> ->
              {ok, Chunk, Rest};
          <<_Chunk:Size/binary, _Rest/binary>> when size(_Rest) >= 2 ->
  