org.httpkit.client

*default-client*

dynamic

Specifies the default `HttpClient` used by the `request` function.
Value may be a delay. See also `make-client`.

acl

(acl url & [opts callback])(acl url & [callback])
Issues an async HTTP ACL request. See `request` for details.

copy

(copy url & [opts callback])(copy url & [callback])
Issues an async HTTP COPY request. See `request` for details.

default-client

default-worker_

(delay (new-worker {})), used to handle client callbacks.
See `new-worker` for details.

delete

(delete url & [opts callback])(delete url & [callback])
Issues an async HTTP DELETE request. See `request` for details.

get

(get url & [opts callback])(get url & [callback])
Issues an async HTTP GET request. See `request` for details.

head

(head url & [opts callback])(head url & [callback])
Issues an async HTTP HEAD request. See `request` for details.

legacy-client

lock

(lock url & [opts callback])(lock url & [callback])
Issues an async HTTP LOCK request. See `request` for details.

make-client

(make-client {:keys [max-connections address-finder ssl-configurer error-logger event-logger event-names bind-address channel-factory]})
Returns an HttpClient with specified options:
:max-connections    ; Max connection count, default is unlimited (-1)
:address-finder     ; (fn [java.net.URI]) -> `java.net.SocketAddress`
:channel-factory    ; (fn [java.net.SocketAddress]) -> `java.nio.channels.SocketChannel`
:ssl-configurer     ; (fn [javax.net.ssl.SSLEngine java.net.URI])
:error-logger       ; (fn [text ex])
:event-logger       ; (fn [event-name])
:event-names        ; {<http-kit-event-name> <loggable-event-name>}
:bind-address       ; when present will pass local address to SocketChannel.bind()

make-ssl-engine

(make-ssl-engine)(make-ssl-engine ctx)
Returns an SSLEngine using default or given SSLContext.

max-body-filter

(max-body-filter size)
reject if response's body exceeds size in bytes

move

(move url & [opts callback])(move url & [callback])
Issues an async HTTP MOVE request. See `request` for details.

new-worker

(new-worker {:keys [queue-size n-min-threads n-max-threads prefix allow-virtual?], :as opts})
Returns {:keys [n-cores type pool ...]} where `:pool` is a new
`java.util.concurrent.ExecutorService` for handling client callbacks.

When on JVM 21+, uses `newVirtualThreadPerTaskExecutor` by default.
Otherwise creates a standard `ThreadPoolExecutor` with default min and max
thread count auto-selected based on currently available processor count.

options

(options url & [opts callback])(options url & [callback])
Issues an async HTTP OPTIONS request. See `request` for details.

patch

(patch url & [opts callback])(patch url & [callback])
Issues an async HTTP PATCH request. See `request` for details.

post

(post url & [opts callback])(post url & [callback])
Issues an async HTTP POST request. See `request` for details.

propfind

(propfind url & [opts callback])(propfind url & [callback])
Issues an async HTTP PROPFIND request. See `request` for details.

proppatch

(proppatch url & [opts callback])(proppatch url & [callback])
Issues an async HTTP PROPPATCH request. See `request` for details.

put

(put url & [opts callback])(put url & [callback])
Issues an async HTTP PUT request. See `request` for details.

query-string

(query-string m)(query-string m style)
Returns URL-encoded query string for given params map.

report

(report url & [opts callback])(report url & [callback])
Issues an async HTTP REPORT request. See `request` for details.

request

(request {:keys [client timeout connect-timeout idle-timeout filter worker-pool keepalive as follow-redirects max-redirects response trace-redirects allow-unsafe-redirect-methods proxy-host proxy-port proxy-url tunnel? deadlock-guard? auto-compression? insecure? nested-param-style], :as opts, :or {auto-compression? true, idle-timeout 60000, proxy-port -1, tunnel? false, response (promise), follow-redirects true, proxy-url nil, as :auto, deadlock-guard? true, proxy-host nil, max-redirects 10, keepalive 120000, filter IFilter/ACCEPT_ALL, connect-timeout 60000}} & [callback])
Issues an async HTTP request and returns a promise object to which the value
of `(callback {:opts _ :status _ :headers _ :body _})` or
   `(callback {:opts _ :error _})` will be delivered.
The latter will be delivered on client errors only, not on http errors which will be
contained in the :status of the first.

;; Asynchronous GET request (returns a promise)
(request {:url "http://www.cnn.com"})

;; Asynchronous GET request with callback
(request {:url "http://www.cnn.com" :method :get}
  (fn [{:keys [opts status body headers error] :as resp}]
    (if error
      (println "Error on" opts)
      (println "Success on" opts))))

;; Synchronous requests
@(request ...) or (deref (request ...) timeout-ms timeout-val)

;; Issue 2 concurrent requests, then wait for results
(let [resp1 (request ...)
      resp2 (request ...)]
  (println "resp1's status: " (:status @resp1))
  (println "resp2's status: " (:status @resp2)))

Returned body type is controlled by `:as` option:

  Without automatic unzipping:
    `:none`           - org.httpkit.DynamicBytes
    `:raw-byte-array` - bytes[]

  With automatic unzipping:
    `:byte-array`     - bytes[]
    `:stream`         - ByteInputStream
    `:text`           - String (charset based on Content-Type header)
    `:auto`           - As `:text` or `:stream` (based on Content-Type header)

Request options:
  :url :method :headers :timeout :connect-timeout :idle-timeout :query-params
  :as :form-params :client :body :basic-auth :user-agent :filter :worker-pool

  :nested-param-style - ∈ #{:comma-separated :array :indexed nil} (default nil)

unlock

(unlock url & [opts callback])(unlock url & [callback])
Issues an async HTTP UNLOCK request. See `request` for details.

url-encode

(url-encode s)