net.http.chunk — org.spootnik/net 0.3.3-beta43

backpressure-fn clj

(backpressure-fn ctx)

Stop automatically reading from the body channel when we are signalled for backpressure.

body-chan clj

(body-chan inbuf {:keys [reducer xf init]})

chunk->http-object clj

(chunk->http-object chunk)

ChunkEncoder clj protocol

A simple encoding protocol for chunks

any->http-object clj

(any->http-object chunk)

Convert arbitrary data to an HttpContent instance

close-fn clj

(close-fn msg ctx)

A closure over a context that will close it when called.

content-chunk? clj

(content-chunk? x)

Predicate to check for ChunkEncoder compliance

enqueue clj

(enqueue sink ctx msg)

(enqueue sink ctx msg close?)

file-chunk clj

(file-chunk f)

Create an input stream chunk from a File

input-stream-chunk clj

(input-stream-chunk is)

Fill up a ByteBuf with the contents of an input stream

prepare-body clj

(prepare-body x)

start-write-listener clj

(start-write-listener ctx ch)

write-listener-callback clj

(write-listener-callback listener ctx)

Used hand in hand with