0
Fork 0
mirror of https://github.com/ninenines/cowboy.git synced 2025-07-15 12:40:25 +00:00

Add a REST example that streams its response

This commit is contained in:
Adam Cammack 2013-02-10 13:54:51 -06:00
parent bce7b860ee
commit f9dd3c9e54
9 changed files with 208 additions and 0 deletions

View file

@ -0,0 +1,38 @@
%% Feel free to use, reuse and abuse the code in this file.
%% @private
-module(rest_stream_response_app).
-behaviour(application).
%% API.
-export([start/2]).
-export([stop/1]).
%% API.
start(_Type, _Args) ->
Table = ets:new(stream_tab, []),
generate_rows(Table, 1000),
Dispatch = cowboy_router:compile([
{'_', [
{"/[:v1]", [{v1, int}], toppage_handler, Table}
]}
]),
{ok, _} = cowboy:start_http(http, 100, [{port, 8080}], [
{env, [{dispatch, Dispatch}]}
]),
rest_stream_response_sup:start_link().
stop(_State) ->
ok.
generate_rows(_Table, 0) -> ok;
generate_rows(Table, N) ->
ets:insert(Table, {key(), val(), val()}),
generate_rows(Table, N - 1).
key() -> key(10).
key(N) -> key(<< (random:uniform(26) - 1) >>, N - 1).
key(Acc, 0) -> binary_part(base64:encode(Acc), 0, 8);
key(Acc, N) -> key(<< Acc/binary, (random:uniform(26) - 1) >>, N - 1).
val() -> random:uniform(50).