Composable streams of tasks

Initial prototype