diff options
Diffstat (limited to 'examples/eventsource/src/eventsource_handler.erl')
| -rw-r--r-- | examples/eventsource/src/eventsource_handler.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/examples/eventsource/src/eventsource_handler.erl b/examples/eventsource/src/eventsource_handler.erl index 6dced4b..d4f51c1 100644 --- a/examples/eventsource/src/eventsource_handler.erl +++ b/examples/eventsource/src/eventsource_handler.erl @@ -6,15 +6,15 @@ -export([init/2]). -export([info/3]). -init(Req, Opts) -> - Req2 = cowboy_req:chunked_reply(200, #{ +init(Req0, Opts) -> + Req = cowboy_req:stream_reply(200, #{ <<"content-type">> => <<"text/event-stream">> - }, Req), + }, Req0), erlang:send_after(1000, self(), {message, "Tick"}), - {cowboy_loop, Req2, Opts, 5000}. + {cowboy_loop, Req, Opts, 5000}. info({message, Msg}, Req, State) -> - cowboy_req:chunk(["id: ", id(), "\ndata: ", Msg, "\n\n"], Req), + cowboy_req:stream_body(["id: ", id(), "\ndata: ", Msg, "\n\n"], nofin, Req), erlang:send_after(1000, self(), {message, "Tick"}), {ok, Req, State}. |