std.concurrent.relay.transport

+read-alias+

bytes-output

added in 4.0

(bytes-output)

creates a byte output stream

mock-input-stream

added in 4.0

(mock-input-stream out)

creates a mock input stream

op-clean

added in 4.0

(op-clean {:keys [raw], :as istream})

cleans the current input stream

op-clean-some

added in 4.0

(op-clean-some istream timeout interval)

cleans until timeout

op-count

added in 4.0

(op-count {:keys [raw], :as istream})

outputs the count in the stream

op-read-all

added in 4.0

(op-read-all istream)

reads all bytes from stream as string

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