aboutsummaryrefslogtreecommitdiffstats
path: root/src/gun_sse.erl
diff options
context:
space:
mode:
authorLoïc Hoguin <[email protected]>2018-06-03 21:11:28 +0200
committerLoïc Hoguin <[email protected]>2018-06-03 21:11:28 +0200
commit1be0151ec7b6a98064e648d5598f56cbdec65dc7 (patch)
tree48cab796ea085c658d799b8d10dbc638d9e43934 /src/gun_sse.erl
parent34307a584149abbf0b2e5b33beb2fca4c585b0d1 (diff)
downloadgun-1be0151ec7b6a98064e648d5598f56cbdec65dc7.tar.gz
gun-1be0151ec7b6a98064e648d5598f56cbdec65dc7.tar.bz2
gun-1be0151ec7b6a98064e648d5598f56cbdec65dc7.zip
Rename gun_data and gun_sse to gun_data_h and gun_sse_h
Diffstat (limited to 'src/gun_sse.erl')
-rw-r--r--src/gun_sse.erl55
1 files changed, 0 insertions, 55 deletions
diff --git a/src/gun_sse.erl b/src/gun_sse.erl
deleted file mode 100644
index 4a898d4..0000000
--- a/src/gun_sse.erl
+++ /dev/null
@@ -1,55 +0,0 @@
-%% Copyright (c) 2017, Loïc Hoguin <[email protected]>
-%%
-%% Permission to use, copy, modify, and/or distribute this software for any
-%% purpose with or without fee is hereby granted, provided that the above
-%% copyright notice and this permission notice appear in all copies.
-%%
-%% THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
-%% WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
-%% MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
-%% ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
-%% WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
-%% ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
-%% OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
-
--module(gun_sse).
--behavior(gun_content_handler).
-
--export([init/5]).
--export([handle/3]).
-
--record(state, {
- reply_to :: pid(),
- stream_ref :: reference(),
- sse_state :: cow_sse:state()
-}).
-
-%% @todo In the future we want to allow different media types.
-%% @todo For text/event-stream specifically, the parameters must be ignored.
-
--spec init(pid(), reference(), _, cow_http:headers(), _)
- -> {ok, #state{}} | disable.
-init(ReplyTo, StreamRef, _, Headers, _) ->
- case lists:keyfind(<<"content-type">>, 1, Headers) of
- {_, <<"text/event-stream">>} ->
- {ok, #state{reply_to=ReplyTo, stream_ref=StreamRef,
- sse_state=cow_sse:init()}};
- _ ->
- disable
- end.
-
--spec handle(_, binary(), State) -> {done, State} when State::#state{}.
-handle(IsFin, Data, State=#state{reply_to=ReplyTo, stream_ref=StreamRef, sse_state=SSE0}) ->
- case cow_sse:parse(Data, SSE0) of
- {event, Event, SSE} ->
- ReplyTo ! {gun_sse, self(), StreamRef, Event},
- handle(IsFin, <<>>, State#state{sse_state=SSE});
- {more, SSE} ->
- _ = case IsFin of
- fin ->
- ReplyTo ! {gun_sse, self(), StreamRef, fin};
- _ ->
- ok
- end,
- {done, State#state{sse_state=SSE}}
- end.