onyx.tasks.core-async — org.onyxplatform/onyx 0.13.3-alpha1

default-channel-size clj

input clj

(input task-name opts)

(input task-name opts chan-size)

Inputs: ([task-name :- s/Keyword opts] [task-name :- s/Keyword opts chan-size])

output clj

(output task-name opts)

(output task-name opts chan-size)

Inputs: ([task-name :- s/Keyword opts] [task-name :- s/Keyword opts chan-size])