mirror of
https://github.com/ninenines/cowboy.git
synced 2025-07-14 12:20:24 +00:00
Update examples to the new interface
This commit is contained in:
parent
00f3ae7d20
commit
ae95e87eb1
5 changed files with 11 additions and 11 deletions
|
@ -6,10 +6,10 @@
|
||||||
-export([init/2]).
|
-export([init/2]).
|
||||||
|
|
||||||
init(Req, Opts) ->
|
init(Req, Opts) ->
|
||||||
cowboy_req:chunked_reply(200, Req),
|
cowboy_req:stream_reply(200, Req),
|
||||||
cowboy_req:chunk("Hello\r\n", Req),
|
cowboy_req:stream_body("Hello\r\n", nofin, Req),
|
||||||
timer:sleep(1000),
|
timer:sleep(1000),
|
||||||
cowboy_req:chunk("World\r\n", Req),
|
cowboy_req:stream_body("World\r\n", nofin, Req),
|
||||||
timer:sleep(1000),
|
timer:sleep(1000),
|
||||||
cowboy_req:chunk("Chunked!\r\n", Req),
|
cowboy_req:stream_body("Chunked!\r\n", fin, Req),
|
||||||
{ok, Req, Opts}.
|
{ok, Req, Opts}.
|
||||||
|
|
|
@ -7,8 +7,8 @@
|
||||||
|
|
||||||
init(Req, Opts) ->
|
init(Req, Opts) ->
|
||||||
NewValue = integer_to_list(rand:uniform(1000000)),
|
NewValue = integer_to_list(rand:uniform(1000000)),
|
||||||
Req2 = cowboy_req:set_resp_cookie(
|
Req2 = cowboy_req:set_resp_cookie(<<"server">>, NewValue,
|
||||||
<<"server">>, NewValue, [{path, <<"/">>}], Req),
|
#{path => <<"/">>}, Req),
|
||||||
#{client := ClientCookie, server := ServerCookie}
|
#{client := ClientCookie, server := ServerCookie}
|
||||||
= cowboy_req:match_cookies([{client, [], <<>>}, {server, [], <<>>}], Req2),
|
= cowboy_req:match_cookies([{client, [], <<>>}, {server, [], <<>>}], Req2),
|
||||||
{ok, Body} = toppage_dtl:render([
|
{ok, Body} = toppage_dtl:render([
|
||||||
|
|
|
@ -12,7 +12,7 @@ init(Req, Opts) ->
|
||||||
{ok, Req2, Opts}.
|
{ok, Req2, Opts}.
|
||||||
|
|
||||||
maybe_echo(<<"POST">>, true, Req) ->
|
maybe_echo(<<"POST">>, true, Req) ->
|
||||||
{ok, PostVals, Req2} = cowboy_req:body_qs(Req),
|
{ok, PostVals, Req2} = cowboy_req:read_urlencoded_body(Req),
|
||||||
Echo = proplists:get_value(<<"echo">>, PostVals),
|
Echo = proplists:get_value(<<"echo">>, PostVals),
|
||||||
echo(Echo, Req2),
|
echo(Echo, Req2),
|
||||||
Req2;
|
Req2;
|
||||||
|
|
|
@ -7,14 +7,14 @@
|
||||||
-export([info/3]).
|
-export([info/3]).
|
||||||
|
|
||||||
init(Req, Opts) ->
|
init(Req, Opts) ->
|
||||||
Req2 = cowboy_req:chunked_reply(200, #{
|
cowboy_req:stream_reply(200, #{
|
||||||
<<"content-type">> => <<"text/event-stream">>
|
<<"content-type">> => <<"text/event-stream">>
|
||||||
}, Req),
|
}, Req),
|
||||||
erlang:send_after(1000, self(), {message, "Tick"}),
|
erlang:send_after(1000, self(), {message, "Tick"}),
|
||||||
{cowboy_loop, Req2, Opts, 5000}.
|
{cowboy_loop, Req, Opts, 5000}.
|
||||||
|
|
||||||
info({message, Msg}, Req, State) ->
|
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"}),
|
erlang:send_after(1000, self(), {message, "Tick"}),
|
||||||
{ok, Req, State}.
|
{ok, Req, State}.
|
||||||
|
|
||||||
|
|
|
@ -44,7 +44,7 @@ resource_exists(Req, _State) ->
|
||||||
|
|
||||||
create_paste(Req, State) ->
|
create_paste(Req, State) ->
|
||||||
PasteID = new_paste_id(),
|
PasteID = new_paste_id(),
|
||||||
{ok, [{<<"paste">>, Paste}], Req2} = cowboy_req:body_qs(Req),
|
{ok, [{<<"paste">>, Paste}], Req2} = cowboy_req:read_urlencoded_body(Req),
|
||||||
ok = file:write_file(full_path(PasteID), Paste),
|
ok = file:write_file(full_path(PasteID), Paste),
|
||||||
case cowboy_req:method(Req2) of
|
case cowboy_req:method(Req2) of
|
||||||
<<"POST">> ->
|
<<"POST">> ->
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue