net.http.chunk
backpressure-fn
(backpressure-fn ctx)
Stop automatically reading from the body channel when we are signalled for backpressure.
body-chan
(body-chan inbuf {:keys [reducer xf init]})
chunk->http-object
(chunk->http-object chunk)
ChunkEncoder
protocol
A simple encoding protocol for chunks
members
any->http-object
(any->http-object chunk)
Convert arbitrary data to an HttpContent instance
close-fn
(close-fn msg ctx)
A closure over a context that will close it when called.
content-chunk?
(content-chunk? x)
Predicate to check for ChunkEncoder compliance
enqueue
(enqueue sink ctx msg)
(enqueue sink ctx msg close?)
file-chunk
(file-chunk f)
Create an input stream chunk from a File
prepare-body
(prepare-body x)
start-write-listener
(start-write-listener ctx ch)
write-listener-callback
(write-listener-callback listener ctx)