onyx.tasks.core-async
default-channel-size
input
(input task-name opts)(input task-name opts chan-size)Inputs: ([task-name :- s/Keyword opts] [task-name :- s/Keyword opts chan-size])
output
(output task-name opts)(output task-name opts chan-size)Inputs: ([task-name :- s/Keyword opts] [task-name :- s/Keyword opts chan-size])