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

input-stream-chunk

(input-stream-chunk is)

Fill up a ByteBuf with the contents of an input stream

prepare-body

(prepare-body x)

start-write-listener

(start-write-listener ctx ch)

write-listener-callback

(write-listener-callback listener ctx)

Used hand in hand with