Fix parsing of event spanning multiple parse calls

1 files changed, 12 insertions, 4 deletions

diff --git a/src/cow_sse.erl b/src/cow_sse.erl
index 710e9b3..201989f 100644
--- a/src/cow_sse.erl
+++ b/src/cow_sse.erl
@@ -64,14 +64,14 @@ parse(Data0, State=#state{state_name=bom, buffer=Buffer}) ->
 parse(<<>>, State=#state{buffer=Buffer}) ->
 	parse_event(Buffer, State#state{buffer= <<>>});
 %% Otherwise process the input data as-is.
-parse(Data, State) ->
-	parse_event(Data, State).
-
-parse_event(Data0, State0=#state{buffer=Buffer}) ->
+parse(Data0, State=#state{buffer=Buffer}) ->
 	Data = case Buffer of
 		<<>> -> Data0;
 		_ -> << Buffer/binary, Data0/binary >>
 	end,
+	parse_event(Data, State).
+
+parse_event(Data, State0) ->
 	case binary:split(Data, [<<"\r\n">>, <<"\r">>, <<"\n">>]) of
 		[Line, Rest] ->
 			case parse_line(Line, State0) of
@@ -211,4 +211,12 @@ parse_example4_test() ->
 	{more, _} = parse(<<>>, State),
 	ok.
 
+parse_split_event_test() ->
+	{more, State} = parse(<<
+		"data: AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA"
+		"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA"
+		"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA">>, init()),
+	{event, _, _} = parse(<<"==\n\n">>, State),
+	ok.
+
 -endif.