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])