Skip to content

Instantly share code, notes, and snippets.

@qzagarese
Created August 1, 2020 10:20
Show Gist options
  • Save qzagarese/566a5f7b56cf525b876c28ae05ec243e to your computer and use it in GitHub Desktop.
Save qzagarese/566a5f7b56cf525b876c28ae05ec243e to your computer and use it in GitHub Desktop.
type: flow
name: producer-consumer
input:
- name: howMany
- name: millisBetweenNumbers
output:
- name: double-value
target: ${consumer.output.output}
pipes:
- as: slow-printer
type: slow-printer
input:
- target: ${howMany}
value: ${flow.input.howMany}
- target: ${millisBetweenNumbers}
value: ${flow.input.millisBetweenNumbers}
output:
- as: output
target: ${output}
- as: consumer
type: simple-consumer
input:
- target: ${source}
value: ${slow-printer.output.output}
usable: WHILE_BEING_PRODUCED
output:
- target: ${output}
as: output
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment