net.transform.split — spootnik/net 0.3.3-beta40

A generic splitting transducer for collections of ByteBuf instances To help the splitting process, and to allow other types of splitting to occur, two protocols are provided.

bytes-needed clj

(bytes-needed parser kept buf)

Figure out how many bytes need to be read to finish this split.

ContentSplitter clj protocol

offer clj

(offer this buf)

Augment a splitter instance with a new buffer, yielding a vector of the updated splitter and a new buffer if one was found.

HeaderParser clj protocol

header-length clj

(header-length this buf)

Yield length of header needed to compute the length of the split, if possible.

payload-length clj

(payload-length this mark kept buf)

Yield the length of the full split payload, this assumes header-length was called and returned.

Initializer clj protocol

initialize! clj

(initialize! this)

Initialize a splitter, called everytime a new buffer is output to reset internal state.

parse-split clj

(parse-split stored buf)

With a new buffer, augment a splitter by consuming all data from the buffer. Yields a vector of the augmented splitter and a sequence of new buffers to output, if any.

raw-split clj

(raw-split splitter)

A transducer that yields collections of ByteBuf instances, from a collection of ByteBuf instances, splitting with the help of a ContentSplitter implementation.

split clj

(split splitter)

Facility function to create a splitter which yields a single collection of ByteBuf instances.