(consume in out connection f)
Takes an inport, outport, connection map, and function. Recursively takes from import, applies f to it asynchronously. Exits when the connection is drained.
Takes an inport, outport, connection map, and function. Recursively takes from import, applies f to it asynchronously. Exits when the connection is drained.
(iounit!)
Maximum iounit for messages.
Maximum iounit for messages.
(state! data)
Update the state, and return a frame. Takes a map of the form: {:update fn-to-apply-to-state-atom :reply {:field-to-add 1 :another-field 2}}
Update the state, and return a frame. Takes a map of the form: {:update fn-to-apply-to-state-atom :reply {:field-to-add 1 :another-field 2}}
(state-handler frame connection out)
An example state handler. Takes in a frame
, the state
atom, and an outport.
Messages that reach a 9P server can be executed in any order, and it is the job
of the client to ensure that it does not send conflicting messages before the
acknowledgement of a previous action has been sent. Therefore, this can be
executed asynchronously inside a future.
An example state handler. Takes in a `frame`, the `state` atom, and an outport. Messages that reach a 9P server can be executed in any order, and it is the job of the client to ensure that it does not send conflicting messages before the acknowledgement of a previous action has been sent. Therefore, this can be executed asynchronously inside a future.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close