Algiras/KafkaGreyhound_10.scala

Created December 11, 2020 14:34

Star () You must be signed in to star a gist
Fork () You must be signed in to fork a gist

Learn more about clone URLs
Clone this repository at <script src="https://gist.github.com/Algiras/f440da4c410404858357023f2b7be080.js"></script>
Save Algiras/f440da4c410404858357023f2b7be080 to your computer and use it in GitHub Desktop.

Download ZIP

Raw

KafkaGreyhound_10.scala

	cronService.stream.flatMap(
	job => ZStream.fromEffect(actionLogTopic.record(ActionRequest(job.id)))
	).runDrain.fork.toManaged_

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment