diff options
author | Herman Singh <[email protected]> | 2018-09-07 13:48:43 -0400 |
---|---|---|
committer | Loïc Hoguin <[email protected]> | 2018-09-23 14:12:38 +0200 |
commit | 86cb105679ff80214bfc9d979afa27b1eb747307 (patch) | |
tree | 873da2ab17c954c9fdf5e8adc5458212274b6c41 /examples/eventsource/src/eventsource_h.erl | |
parent | 8045f7a998f03b8995d30dc14b3308e9a67422bc (diff) | |
download | cowboy-86cb105679ff80214bfc9d979afa27b1eb747307.tar.gz cowboy-86cb105679ff80214bfc9d979afa27b1eb747307.tar.bz2 cowboy-86cb105679ff80214bfc9d979afa27b1eb747307.zip |
Rename handler modules to _h
Diffstat (limited to 'examples/eventsource/src/eventsource_h.erl')
-rw-r--r-- | examples/eventsource/src/eventsource_h.erl | 25 |
1 files changed, 25 insertions, 0 deletions
diff --git a/examples/eventsource/src/eventsource_h.erl b/examples/eventsource/src/eventsource_h.erl new file mode 100644 index 0000000..ba5d866 --- /dev/null +++ b/examples/eventsource/src/eventsource_h.erl @@ -0,0 +1,25 @@ +%% Feel free to use, reuse and abuse the code in this file. + +%% @doc EventSource emitter. +-module(eventsource_h). + +-export([init/2]). +-export([info/3]). + +init(Req0, Opts) -> + Req = cowboy_req:stream_reply(200, #{ + <<"content-type">> => <<"text/event-stream">> + }, Req0), + erlang:send_after(1000, self(), {message, "Tick"}), + {cowboy_loop, Req, Opts}. + +info({message, Msg}, Req, State) -> + cowboy_req:stream_events(#{ + id => id(), + data => Msg + }, nofin, Req), + erlang:send_after(1000, self(), {message, "Tick"}), + {ok, Req, State}. + +id() -> + integer_to_list(erlang:unique_integer([positive, monotonic]), 16). |