aboutsummaryrefslogtreecommitdiffstats
path: root/test/handlers
diff options
context:
space:
mode:
authorLoïc Hoguin <[email protected]>2018-06-27 13:40:11 +0200
committerLoïc Hoguin <[email protected]>2018-06-27 13:40:11 +0200
commit0fb68ec07fa8096ecbc124896b56297fad818ae0 (patch)
tree27b61b3ae2fcff6da09450242a22f18cb3537c5b /test/handlers
parentfaefb634de2874cafaf7f2d7fb7d4f8eab9019a9 (diff)
downloadcowboy-0fb68ec07fa8096ecbc124896b56297fad818ae0.tar.gz
cowboy-0fb68ec07fa8096ecbc124896b56297fad818ae0.tar.bz2
cowboy-0fb68ec07fa8096ecbc124896b56297fad818ae0.zip
Add test cases for cowboy_req:stream_events
Diffstat (limited to 'test/handlers')
-rw-r--r--test/handlers/resp_h.erl52
1 files changed, 52 insertions, 0 deletions
diff --git a/test/handlers/resp_h.erl b/test/handlers/resp_h.erl
index e924c89..625a2ea 100644
--- a/test/handlers/resp_h.erl
+++ b/test/handlers/resp_h.erl
@@ -246,6 +246,58 @@ do(<<"stream_body_content_length">>, Req0, Opts) ->
cowboy_req:stream_body(<<"Hello">>, nofin, Req),
{ok, Req, Opts}
end;
+do(<<"stream_events">>, Req0, Opts) ->
+ case cowboy_req:binding(arg, Req0) of
+ %%<<"single">>
+ %%<<"list">>
+ <<"single">> ->
+ Req = cowboy_req:stream_reply(200,
+ #{<<"content-type">> => <<"text/event-stream">>},
+ Req0),
+ cowboy_req:stream_events(#{
+ event => <<"add_comment">>,
+ data => <<"Comment text.\nWith many lines.">>
+ }, fin, Req),
+ {ok, Req, Opts};
+ <<"list">> ->
+ Req = cowboy_req:stream_reply(200,
+ #{<<"content-type">> => <<"text/event-stream">>},
+ Req0),
+ cowboy_req:stream_events([
+ #{
+ event => <<"add_comment">>,
+ data => <<"Comment text.\nWith many lines.">>
+ },
+ #{
+ comment => <<"Set retry higher\nwith many lines also.">>,
+ retry => 10000
+ },
+ #{
+ id => <<"123">>,
+ event => <<"add_comment">>,
+ data => <<"Closing!">>
+ }
+ ], fin, Req),
+ {ok, Req, Opts};
+ <<"multiple">> ->
+ Req = cowboy_req:stream_reply(200,
+ #{<<"content-type">> => <<"text/event-stream">>},
+ Req0),
+ cowboy_req:stream_events(#{
+ event => <<"add_comment">>,
+ data => <<"Comment text.\nWith many lines.">>
+ }, nofin, Req),
+ cowboy_req:stream_events(#{
+ comment => <<"Set retry higher\nwith many lines also.">>,
+ retry => 10000
+ }, nofin, Req),
+ cowboy_req:stream_events(#{
+ id => <<"123">>,
+ event => <<"add_comment">>,
+ data => <<"Closing!">>
+ }, fin, Req),
+ {ok, Req, Opts}
+ end;
do(<<"stream_trailers">>, Req0, Opts) ->
case cowboy_req:binding(arg, Req0) of
<<"large">> ->