aboutsummaryrefslogtreecommitdiffstats
path: root/test/handlers/sse_clock_close_h.erl
diff options
context:
space:
mode:
authorBenedikt Reinartz <[email protected]>2021-07-05 11:53:35 +0200
committerLoïc Hoguin <[email protected]>2022-08-30 14:59:17 +0200
commit0724dbf536c22fc978ba0bc96052c65f0edafa69 (patch)
tree16843f327bd6adebf39d69959226aa5ef3db02c2 /test/handlers/sse_clock_close_h.erl
parent1f42d14e88fe028295a66878140750fee0f93892 (diff)
downloadgun-0724dbf536c22fc978ba0bc96052c65f0edafa69.tar.gz
gun-0724dbf536c22fc978ba0bc96052c65f0edafa69.tar.bz2
gun-0724dbf536c22fc978ba0bc96052c65f0edafa69.zip
Add tests for the SSE handler
Diffstat (limited to 'test/handlers/sse_clock_close_h.erl')
-rw-r--r--test/handlers/sse_clock_close_h.erl23
1 files changed, 23 insertions, 0 deletions
diff --git a/test/handlers/sse_clock_close_h.erl b/test/handlers/sse_clock_close_h.erl
new file mode 100644
index 0000000..c5911ff
--- /dev/null
+++ b/test/handlers/sse_clock_close_h.erl
@@ -0,0 +1,23 @@
+%% This module implements a loop handler that sends
+%% the current time every second using SSE. In contrast
+%% to sse_clock_h, this one sends a "Connection: close"
+%% header.
+
+-module(sse_clock_close_h).
+
+-export([init/2]).
+-export([info/3]).
+
+init(Req, State) ->
+ self() ! timeout,
+ {cowboy_loop, cowboy_req:stream_reply(200, #{
+ <<"content-type">> => <<"text/event-stream">>,
+ <<"connection">> => <<"close">>
+ }, Req), State}.
+
+info(timeout, Req, State) ->
+ erlang:send_after(1000, self(), timeout),
+ cowboy_req:stream_events(#{
+ data => cowboy_clock:rfc1123()
+ }, nofin, Req),
+ {ok, Req, State}.