Permalink
Switch branches/tags
Find file
Fetching contributors…
Cannot retrieve contributors at this time
40 lines (32 sloc) 1.11 KB
-module(sample_ws_handler).
-behaviour(websocket_client_handler).
-export([
start_link/0,
init/2,
websocket_handle/3,
websocket_info/3,
websocket_terminate/3
]).
start_link() ->
crypto:start(),
ssl:start(),
websocket_client:start_link("wss://echo.websocket.org", ?MODULE, []).
init([], _ConnState) ->
websocket_client:cast(self(), {text, <<"message 1">>}),
{ok, 2}.
websocket_handle({pong, _}, _ConnState, State) ->
{ok, State};
websocket_handle({text, Msg}, _ConnState, 5) ->
io:format("Received msg ~p~n", [Msg]),
{close, <<>>, "done"};
websocket_handle({text, Msg}, _ConnState, State) ->
io:format("Received msg ~p~n", [Msg]),
timer:sleep(1000),
BinInt = list_to_binary(integer_to_list(State)),
{reply, {text, <<"hello, this is message #", BinInt/binary >>}, State + 1}.
websocket_info(start, _ConnState, State) ->
{reply, {text, <<"erlang message received">>}, State}.
websocket_terminate(Reason, _ConnState, State) ->
io:format("Websocket closed in state ~p wih reason ~p~n",
[State, Reason]),
ok.