|
@@ -22,12 +22,11 @@ content_types_provided(Req, State) ->
|
|
streaming_csv(Req, Table) ->
|
|
streaming_csv(Req, Table) ->
|
|
{N, Req1} = cowboy_req:binding(v1, Req, 1),
|
|
{N, Req1} = cowboy_req:binding(v1, Req, 1),
|
|
MS = [{{'$1', '$2', '$3'}, [{'==', '$2', N}], ['$$']}],
|
|
MS = [{{'$1', '$2', '$3'}, [{'==', '$2', N}], ['$$']}],
|
|
-
|
|
|
|
{{stream, result_streamer(Table, MS)}, Req1, Table}.
|
|
{{stream, result_streamer(Table, MS)}, Req1, Table}.
|
|
|
|
|
|
result_streamer(Table, MS) ->
|
|
result_streamer(Table, MS) ->
|
|
fun (Socket, Transport) ->
|
|
fun (Socket, Transport) ->
|
|
- send_records(Socket, Transport, ets:select(Table, MS, 1))
|
|
|
|
|
|
+ send_records(Socket, Transport, ets:select(Table, MS, 1))
|
|
end.
|
|
end.
|
|
|
|
|
|
send_records(Socket, Transport, {[Rec], Cont}) ->
|
|
send_records(Socket, Transport, {[Rec], Cont}) ->
|