mirror of
https://github.com/ninenines/cowboy.git
synced 2025-07-14 12:20:24 +00:00
Add shortcuts to reply functions
New functions are reply/2, reply/3, chunked_reply/2 in cowboy_http_req.
This commit is contained in:
parent
2a324aca3a
commit
81cc99d10b
5 changed files with 21 additions and 5 deletions
|
@ -37,7 +37,8 @@
|
|||
]). %% Request Body API.
|
||||
|
||||
-export([
|
||||
reply/4, chunked_reply/3, chunk/2
|
||||
reply/2, reply/3, reply/4,
|
||||
chunked_reply/2, chunked_reply/3, chunk/2
|
||||
]). %% Response API.
|
||||
|
||||
-export([
|
||||
|
@ -312,6 +313,16 @@ body_qs(Req) ->
|
|||
|
||||
%% Response API.
|
||||
|
||||
%% @equiv reply(Status, [], [], Req)
|
||||
-spec reply(http_status(), #http_req{}) -> {ok, #http_req{}}.
|
||||
reply(Status, Req) ->
|
||||
reply(Status, [], [], Req).
|
||||
|
||||
%% @equiv reply(Status, Headers, [], Req)
|
||||
-spec reply(http_status(), http_headers(), #http_req{}) -> {ok, #http_req{}}.
|
||||
reply(Status, Headers, Req) ->
|
||||
reply(Status, Headers, [], Req).
|
||||
|
||||
%% @doc Send a reply to the client.
|
||||
-spec reply(http_status(), http_headers(), iodata(), #http_req{})
|
||||
-> {ok, #http_req{}}.
|
||||
|
@ -332,6 +343,11 @@ reply(Status, Headers, Body, Req=#http_req{socket=Socket,
|
|||
end,
|
||||
{ok, Req#http_req{connection=RespConn, resp_state=done}}.
|
||||
|
||||
%% @equiv chunked_reply(Status, [], Req)
|
||||
-spec chunked_reply(http_status(), #http_req{}) -> {ok, #http_req{}}.
|
||||
chunked_reply(Status, Req) ->
|
||||
chunked_reply(Status, [], Req).
|
||||
|
||||
%% @doc Initiate the sending of a chunked reply to the client.
|
||||
%% @see cowboy_http_req:chunk/2
|
||||
-spec chunked_reply(http_status(), http_headers(), #http_req{})
|
||||
|
|
|
@ -8,7 +8,7 @@ init({_Transport, http}, Req, _Opts) ->
|
|||
{ok, Req, undefined}.
|
||||
|
||||
handle(Req, State) ->
|
||||
{ok, Req2} = cowboy_http_req:chunked_reply(200, [], Req),
|
||||
{ok, Req2} = cowboy_http_req:chunked_reply(200, Req),
|
||||
cowboy_http_req:chunk("chunked_handler\r\n", Req2),
|
||||
cowboy_http_req:chunk("works fine!", Req2),
|
||||
{ok, Req2, State}.
|
||||
|
|
|
@ -6,7 +6,7 @@
|
|||
|
||||
init({_Transport, http}, Req, _Opts) ->
|
||||
Req2 = cowboy_http_req:reply(<<"666 Init Shutdown Testing">>,
|
||||
[{'Connection', <<"close">>}], [], Req),
|
||||
[{'Connection', <<"close">>}], Req),
|
||||
{shutdown, Req2, undefined}.
|
||||
|
||||
handle(Req, State) ->
|
||||
|
|
|
@ -12,7 +12,7 @@ handle(_Req, _State) ->
|
|||
exit(badarg).
|
||||
|
||||
info(timeout, Req, 0) ->
|
||||
{ok, Req2} = cowboy_http_req:reply(102, [], [], Req),
|
||||
{ok, Req2} = cowboy_http_req:reply(102, Req),
|
||||
{ok, Req2, 0};
|
||||
info(timeout, Req, State) ->
|
||||
erlang:send_after(500, self(), timeout),
|
||||
|
|
|
@ -17,7 +17,7 @@ terminate(_Req, _State) ->
|
|||
exit(badarg).
|
||||
|
||||
websocket_init(_TransportName, Req, _Opts) ->
|
||||
Req2 = cowboy_http_req:reply(403, [], [], Req),
|
||||
Req2 = cowboy_http_req:reply(403, Req),
|
||||
{shutdown, Req2}.
|
||||
|
||||
websocket_handle(_Frame, _Req, _State) ->
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue