(timeout time.Duration)
| 56 | } |
| 57 | |
| 58 | func newRequester(timeout time.Duration) Requester { |
| 59 | tr := http.DefaultTransport.(*http.Transport).Clone() |
| 60 | tr.MaxIdleConnsPerHost = 5 |
| 61 | tr.IdleConnTimeout = 59 * time.Second |
| 62 | tr.ExpectContinueTimeout = 2 * time.Second |
| 63 | |
| 64 | return &http.Client{ |
| 65 | Timeout: timeout, |
| 66 | Transport: tr, |
| 67 | } |
| 68 | } |
| 69 | |
| 70 | // NewFromEnv build a new Client using environment variables values, with |
| 71 | // possible values being STREAM_API_KEY, STREAM_API_SECRET, STREAM_API_REGION, |
no outgoing calls
no test coverage detected