are you using it for stream processing or one-shot...
# rx
j
are you using it for stream processing or one-shot async threading?