Composable, halt-able pipelines in scala