%% multiple_in_one_test() ->
%%     [{binary, Bin1}, _] = examples:hash_response(),
%%     [{binary, Bin2}, _] = examples:post_request(),
%%     {multiple, Msgs} = wire:decode(<<Bin1/binary, Bin2/binary>>),
%%     ?assertEqual(2, length(Msgs)).

chunk_messages_test() ->
    A = crypto:strong_rand_bytes(5),
    ALen = wire:encode_varint(byte_size(A)),
    B = crypto:strong_rand_bytes(10),
    BLen = wire:encode_varint(byte_size(B)),
    C = crypto:strong_rand_bytes(5),
    CLen = wire:encode_varint(byte_size(C)),
    Payload = <<ALen/bytes, A/bytes, BLen/bytes, B/bytes, CLen/bytes, C/bytes>>,
    {ok, [A, B, C]} = wire:split_messages(Payload).
multiple_in_one_test() ->
     [{binary, Bin1}, _] = examples:hash_response(),
     [{binary, Bin2}, _] = examples:post_request(),
     {multiple, Msgs} = wire:decode(<<Bin1/binary, Bin2/binary>>),
     ?assertEqual(2, length(Msgs)).

-export([split_messages/1]).

split_messages(Data) -> split_messages(Data, []).
split_messages(Data, Acc) ->
    {Len, Rest} = decode_varint(Data),
    RestSize = byte_size(Rest),
    if
        Len > RestSize -> erlang:error("Not enough Data for the complete message");
        Len =:= RestSize -> {ok, Acc++[Rest]}; % last call
        Len < RestSize ->
            Msg = binary:part(Rest, 0, Len),
            Next = binary:part(Rest, Len, byte_size(Rest)-Len),
            split_messages(Next, Acc++[Msg])
    end.