Allow setting recv_timeout when sending request

Author: felixyz

src/gleam/hackney.gleam

@@ -21,27 +21,33 @@ fn ffi_send(
   b: String,
   c: List(http.Header),
   d: BytesBuilder,
+  e: Int
 ) -> Result(Response(BitArray), Error)
 
 // TODO: test
 pub fn send_bits(
   request: Request(BytesBuilder),
+  timeout: Int
 ) -> Result(Response(BitArray), Error) {
   use response <- result.then(
     request
     |> request.to_uri
     |> uri.to_string
-    |> ffi_send(request.method, _, request.headers, request.body),
+    |> ffi_send(request.method, _, request.headers, request.body, timeout),
   )
   let headers = list.map(response.headers, normalise_header)
   Ok(Response(..response, headers: headers))
 }
 
 pub fn send(req: Request(String)) -> Result(Response(String), Error) {
+  send_with_timeout(req, 8000)
+}
+
+pub fn send_with_timeout(req: Request(String), timeout: Int) -> Result(Response(String), Error) {
   use resp <- result.then(
     req
     |> request.map(bytes_builder.from_string)
-    |> send_bits,
+    |> send_bits(timeout),
   )
 
   case bit_array.to_string(resp.body) {

src/gleam_hackney_ffi.erl

@@ -1,9 +1,9 @@
 -module(gleam_hackney_ffi).
 
--export([send/4]).
+-export([send/5]).
 
-send(Method, Url, Headers, Body) ->
-    Options = [{with_body, true}],
+send(Method, Url, Headers, Body, Timeout) ->
+    Options = [{with_body, true}, {recv_timeout, Timeout}],
     case hackney:request(Method, Url, Headers, Body, Options) of
         {ok, Status, ResponseHeaders, ResponseBody} -> 
             {ok, {response, Status, ResponseHeaders, ResponseBody}};