From e7a65406a7e429a6fb46465fd4a9a0c3d66d442a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Hoguin?= Date: Wed, 19 Jul 2017 18:42:44 +0200 Subject: Remove the broken examples Hooks are gone, and we won't be able to stream body in REST in Cowboy 2.0-rc.1, and might not in 2.0 either. That is, other than via halting the processing. --- .../rest_stream_response/src/toppage_handler.erl | 37 ---------------------- 1 file changed, 37 deletions(-) delete mode 100644 examples/rest_stream_response/src/toppage_handler.erl (limited to 'examples/rest_stream_response/src/toppage_handler.erl') diff --git a/examples/rest_stream_response/src/toppage_handler.erl b/examples/rest_stream_response/src/toppage_handler.erl deleted file mode 100644 index 61f5ab9..0000000 --- a/examples/rest_stream_response/src/toppage_handler.erl +++ /dev/null @@ -1,37 +0,0 @@ -%% Feel free to use, reuse and abuse the code in this file. - -%% @doc Streaming handler. --module(toppage_handler). - --export([init/2]). --export([content_types_provided/2]). --export([streaming_csv/2]). - -init(Req, Table) -> - {cowboy_rest, Req, Table}. - -content_types_provided(Req, State) -> - {[ - {{<<"text">>, <<"csv">>, []}, streaming_csv} - ], Req, State}. - -streaming_csv(Req, Table) -> - N = cowboy_req:binding(v1, Req, 1), - MS = [{{'$1', '$2', '$3'}, [{'==', '$2', N}], ['$$']}], - {{stream, result_streamer(Table, MS)}, Req, Table}. - -result_streamer(Table, MS) -> - fun (Socket, Transport) -> - send_records(Socket, Transport, ets:select(Table, MS, 1)) - end. - -send_records(Socket, Transport, {[Rec], Cont}) -> - timer:sleep(500), - send_line(Socket, Transport, Rec), - send_records(Socket, Transport, ets:select(Cont)); -send_records(_Socket, _Transport, '$end_of_table') -> - ok. - -send_line(Socket, Transport, [Key, V1, V2]) -> - Transport:send(Socket, - [Key, $,, integer_to_list(V1), $,, integer_to_list(V2), $\r, $\n]). -- cgit v1.2.3