Fix eventsource example

examples/eventsource/src/eventsource_app.erl

@@ -17,9 +17,9 @@ start(_Type, _Args) ->
 			{"/", cowboy_static, {priv_file, eventsource, "index.html"}}
 		]}
 	]),
-	{ok, _} = cowboy:start_http(http, 100, [{port, 8080}], [
+	{ok, _} = cowboy:start_clear(http, 100, [{port, 8080}], #{
-		{env, [{dispatch, Dispatch}]}
+		env => #{dispatch => Dispatch}
-	]),
+	}),
 	eventsource_sup:start_link().
 
 stop(_State) ->

examples/eventsource/src/eventsource_handler.erl

@@ -7,8 +7,9 @@
 -export([info/3]).
 
 init(Req, Opts) ->
-	Headers = [{<<"content-type">>, <<"text/event-stream">>}],
+	Req2 = cowboy_req:chunked_reply(200, #{
-	Req2 = cowboy_req:chunked_reply(200, Headers, Req),
+		<<"content-type">> => <<"text/event-stream">>
+	}, Req),
 	erlang:send_after(1000, self(), {message, "Tick"}),
 	{cowboy_loop, Req2, Opts, 5000}.
 

test/examples_SUITE.erl

@@ -190,6 +190,29 @@ do_echo_post(Transport, Protocol, Config) ->
 	{ok, <<"this is fun">>} = gun:await_body(ConnPid, Ref),
 	ok.
 
+%% Eventsource.
+
+eventsource(Config) ->
+	doc("Eventsource example."),
+	try
+		do_compile_and_start(eventsource),
+		do_eventsource(tcp, http, Config),
+		do_eventsource(tcp, http2, Config)
+	after
+		do_stop(eventsource)
+	end.
+
+do_eventsource(Transport, Protocol, Config) ->
+	ConnPid = gun_open([{port, 8080}, {type, Transport}, {protocol, Protocol}|Config]),
+	Ref = gun:get(ConnPid, "/eventsource"),
+	{response, nofin, 200, Headers} = gun:await(ConnPid, Ref),
+	{_, <<"text/event-stream">>} = lists:keyfind(<<"content-type">>, 1, Headers),
+	%% Receive a few events.
+	{data, nofin, << "id: ", _/bits >>} = gun:await(ConnPid, Ref, 2000),
+	{data, nofin, << "id: ", _/bits >>} = gun:await(ConnPid, Ref, 2000),
+	{data, nofin, << "id: ", _/bits >>} = gun:await(ConnPid, Ref, 2000),
+	gun:close(ConnPid).
+
 %% REST Hello World.
 
 rest_hello_world(Config) ->