onyx.plugin.core-async — org.onyxplatform/onyx 0.14.6

buffers clj/s

channels clj/s

default-channel-size clj/s

get-buffer clj/s

(get-buffer id)

get-channel clj/s

(get-channel id)

(get-channel id size)

get-core-async-channels clj/s

(get-core-async-channels {:keys [catalog lifecycles]})

in-calls clj/s

inject-in-ch clj/s

(inject-in-ch _ lifecycle)

inject-out-ch clj/s

(inject-out-ch _ lifecycle)

input clj/s

(input event)

out-calls clj/s

output clj/s

(output event)

reader-calls clj/s

take-segments! clj

(take-segments! ch)

(take-segments! ch timeout-ms)

Takes segments off the channel until nothing is read for timeout-ms.

writer-calls clj/s