std.concurrent.relay.transport
op-clean
added in 4.0
(op-clean {:keys [raw], :as istream})cleans the current input stream
op-count
added in 4.0
(op-count {:keys [raw], :as istream})outputs the count in the stream
op-read-all-bytes
added in 4.0
(op-read-all-bytes {:keys [raw], :as istream})reads all bytes from the stream
op-read-limit
added in 4.0
(op-read-limit istream limit timeout interval)reads an limited amount of characters from stream or until timeout
op-read-line
added in 4.0
(op-read-line istream timeout interval)read line from stream or until timeout
op-read-some
added in 4.0
(op-read-some istream timeout interval)read bytes from stream until timeout as string
op-read-some-bytes
added in 4.0
(op-read-some-bytes istream timeout interval)read bytes from stream until timeout
process-by-handler
added in 4.0
(process-by-handler {:keys [raw], :as istream} handler msg)process the input with a function
process-by-line
added in 4.0
(process-by-line {:keys [raw], :as istream} line-fn msg)process each line using a function
process-op
added in 4.0
(process-op istream op {:keys [timeout interval limit handler], :as msg})processes an op given a command
read-bytes-limit
added in 4.0
(read-bytes-limit {:keys [raw]} f f-timeout limit timeout interval)reads a limited number of bytes from stream
read-bytes-line
added in 4.0
(read-bytes-line {:keys [raw]} f f-timeout timeout interval)reads individual lines from stream
read-bytes-some
added in 4.0
(read-bytes-some {:keys [raw]} f timeout interval)reads until timeout
send-command
added in 4.0
(send-command istream ostream op line {:keys [direct], :as msg})sends a command to output and then waits on the input
send-write-flush
added in 4.0
(send-write-flush {:keys [raw], :as ostream})sends a raw flush command
send-write-line
added in 4.0
(send-write-line {:keys [raw], :as ostream} line)sends a command with a newline and flush
send-write-raw
added in 4.0
(send-write-raw {:keys [raw], :as ostream} bytes)sends a raw write command